#channel #mpsc #mpmc

channel_pipes

Perform operations on broadcast queues

2 unstable releases

0.2.0 Feb 10, 2022
0.1.0 Feb 7, 2022

#1170 in Concurrency

MIT license

12KB
259 lines

channel_pipes

Crates.io Crates.io Crates.io
GitHub last commit Lines of code

Usage

If you use crossbeam-channel, add this to your Cargo.toml:

[dependencies]
channel_pipes = { version = "0.2", features = ["crossbeam"] }

Examples

use channel_pipes::{operators::DistinctUntilChanged, CrossbeamSender, IntoPiped};
use crossbeam_channel::unbounded;

fn main() {
    let (s, r) = unbounded::<i32>().pipe().distinct_until_changed();

    let vec = vec![1, 2, 2, 3, 3, 3, 1];
    for i in vec {
        s.send(i);
    }

    assert_eq!(Ok(1), r.try_recv());
    assert_eq!(Ok(2), r.try_recv());
    assert_eq!(Ok(3), r.try_recv());
    assert_eq!(Ok(1), r.try_recv());
    assert!(r.try_recv().is_err());
}

Dependencies

~1.6–7MB
~48K SLoC