Tokio Drift

main.rs

use tokio::sync::mpsc;

#[tokio::main]
async fn main() {
    let result = run();
    assert_eq!(result, 2);
}

fn run() -> u32 {
    let (tx, mut rx) = mpsc::channel(32);
    let tx2 = tx.clone();

    tokio::spawn(async move {
        tx.send(()).await.unwrap();
    });

    tokio::spawn(async move {
        tx2.send(()).await.unwrap();
    });

    let mut count = 0;
    while count < 2 {
        let _ = rx.blocking_recv();
        count += 1;
    }
    count
}