1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
use async_stream::stream; use futures_util::pin_mut; use futures_util::stream::StreamExt; #[tokio::test] async fn spans_preserved() { let s = stream! { assert_eq!(line!(), 8); }; pin_mut!(s); while s.next().await.is_some() { unreachable!(); } }