pub fn bounded<T>(buffer: usize) -> (Outputs<T>, Inputs<T>)Examples found in repository?
examples/basic.rs (line 6)
5pub async fn main() {
6 let (outputs, mut inputs) = async_flow::bounded(1);
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}