hyperbridge 0.2.5

Fast multi-producer multi-consumer channel with async support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

//! # Hyperbridge
//!
//! Fast multi-producer, multi-consumer unbounded channel with async support.
//!
//! ## Example
//!
//! ```
//! let (tx, rx) = hyperbridge::channel::new();
//!
//! tx.send(42).unwrap();
//! let v = loop {
//!     match rx.try_recv() {
//!         Ok(None) => {}, // not ready
//!         Ok(Some(val)) => break val,
//!         Err(e) => panic!("channel read error: {:?}", e),
//!     }
//! };
//! assert_eq!(v, 42);
//! ```

#[cfg(feature = "with-futures")]
extern crate futures;

// mpmc channel
pub mod channel;
// Sink, Stream implementations for channel
#[cfg(feature = "with-futures")]
pub mod stream;
// auxiliary tools
pub mod util;