$ flume_

Crate

Name: flume New version: 0.12.0 Release date: 2025-12-08T17:22:31.630716Z

Crate readme

Short description A blazingly fast multi-producer, multi-consumer channel.

Long description Flume provides unbounded, bounded, and rendezvous queues with fast performance due to no use of unsafe code. It features asynchronous support, a select-like interface, and is a drop-in replacement for std::sync::mpsc. It's designed to be simple, ergonomic, and flexible with minimal dependencies.

Features • spin • select • async • eventual-fairness

Code Examples Basic usage

 use std::thread;

fn main() {
    println!("Hello, world!");

    let (tx, rx) = flume::unbounded();

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

    let received: u32 = rx.iter().sum();

    assert_eq!((0..10).sum::<u32>(), received);
}

Add to Cargo.toml

 flume = "x.y"

Feature-flagged usage

 flume = { version = "x.y", default-features = false, features = ["async", "select"] }

Links • https://crates.io/crates/flume • https://docs.rs/flume • https://github.com/zesterer/flume • https://casuallymaintained.tech/

https://docs.rs/flume

Release info

Release version: N/A

Release description N/A

Code Examples N/A