tokio::sync::mpsc

tokio_mpsc.rs

use tokio::sync::mpsc;
//use tokio::time::{Duration, sleep};

#[tokio::main]
async fn main() {
    let (tx, mut rx) = mpsc::channel(100);
    tokio::spawn(async move {
        for i in 0..10 {
            tx.send(format!("event {}", i)).await.unwrap();
        }
    });
    while let Some(msg) = rx.recv().await {
        println!("Received: {}", msg);
    }
}