basic/
basic.rs

1// This is free and unencumbered software released into the public domain.
2
3/// cargo run --example basic
4#[tokio::main(flavor = "current_thread")]
5pub async fn main() {
6    let (outputs, mut inputs) = async_flow::Channel::bounded(1).into_inner();
7
8    tokio::spawn(async move {
9        outputs.send("value1").await.unwrap();
10        outputs.send("value2").await.unwrap();
11    });
12
13    while let Some(message) = inputs.recv().await.unwrap() {
14        eprintln!("recv: {}", message);
15    }
16}
basic/basic.rs

basic/
basic.rs
