2 unstable releases
0.2.0 | Feb 10, 2022 |
---|---|
0.1.0 | Feb 7, 2022 |
#1170 in Concurrency
12KB
259 lines
channel_pipes
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