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