async-stream 0.3.6

Asynchronous streams using async & await notation
Documentation 
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!();
    }
}