async-gen 0.3.0

Async generator in stable rust using async/await
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use async_gen::stream;
use futures::StreamExt;
use nio::net::TcpListener;
use std::pin::pin;

#[nio::main]
async fn main() {
    let mut listener = TcpListener::bind("127.0.0.1:0").await.unwrap();

    let mut incoming = pin!(stream! {
        loop {
            let socket = listener.accept().await.unwrap();
            yield socket.connect().await;
        }
    });

    while let Some(Ok(v)) = incoming.next().await {
        println!("handle = {:?}", v);
    }
}