Loole

A safe async/sync multi-producer multi-consumer channel.

Producers can send and consumers can receive messages asynchronously or synchronously:

async send -> async receive
sync send -> sync receive
async send -> sync receive
sync send -> async receive

fn main() {
    let (tx, rx) = loole::unbounded();

    std::thread::spawn(move || {
        for i in (0..10) {
            tx.send(i).unwrap();
        }
    });

    let mut sum = 0;
    while let Ok(i) = rx.recv() {
        sum += i;
    }

    assert_eq!(sum, (0..10).sum());
}