From 1b6a04ca5504955c571d1c97504fb45ea0befee4 Mon Sep 17 00:00:00 2001 From: Valentin Popov Date: Mon, 8 Jan 2024 01:21:28 +0400 Subject: Initial vendor packages Signed-off-by: Valentin Popov --- vendor/flume/examples/async.rs | 21 +++++++++++++++++++++ 1 file changed, 21 insertions(+) create mode 100644 vendor/flume/examples/async.rs (limited to 'vendor/flume/examples/async.rs') diff --git a/vendor/flume/examples/async.rs b/vendor/flume/examples/async.rs new file mode 100644 index 0000000..a562700 --- /dev/null +++ b/vendor/flume/examples/async.rs @@ -0,0 +1,21 @@ +#[cfg(feature = "async")] +#[async_std::main] +async fn main() { + let (tx, rx) = flume::bounded(1); + + let t = async_std::task::spawn(async move { + while let Ok(msg) = rx.recv_async().await { + println!("Received: {}", msg); + } + }); + + tx.send_async("Hello, world!").await.unwrap(); + tx.send_async("How are you today?").await.unwrap(); + + drop(tx); + + t.await; +} + +#[cfg(not(feature = "async"))] +fn main() {} -- cgit v1.2.3