1 use tokio_stream::{self as stream, Stream, StreamExt}; 2 3 #[tokio::test] basic_usage()4 async fn basic_usage() { 5 let mut stream = stream::empty::<i32>(); 6 7 for _ in 0..2 { 8 assert_eq!(stream.size_hint(), (0, Some(0))); 9 assert_eq!(None, stream.next().await); 10 } 11 } 12