pub fn drain<T>() -> Drain<T>
Expand description
Create a sink that will just discard all items given to it.
Similar to io::Sink
.
ยงExamples
use async_sink::SinkExt;
#[tokio::main]
async fn main() {
let mut drain = async_sink::drain();
assert!(drain.send_all(&mut tokio_stream::iter((1u8..=5u8).map(|i| Ok(i)))).await.is_ok());
assert!(drain.send_all(&mut tokio_stream::iter(b"hello".iter().map(|c| Ok(*c)))).await.is_ok());
}