drain

Function drain 

Source
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());
}