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