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 31 32 33 34
//! The feature-rich, portable async channel library. Provides a set of async channels that can be used with any async executor. //! //! Why use Postage? //! - Includes a **rich set of channels**, and it works with any async executor (currently integration tests cover tokio and async-std) //! - `mpsc`, a multi-producer, single-consumer channel //! - `broadcast`, a multi-producer, multi-consumer broadcast channel with backpressure (no lagging!) //! - `watch`, a stateful channel where receivers receive an initial value, and updates when the value state changes. //! - `oneshot`, a transfer channel that can be used once. //! - `barrier`, a channel that doesn't carry a value, but transmits when the sender half is dropped. //! - Comes with **built-in Stream and Sink combinators**. //! - Sinks can be chained, and filtered. //! - Streams can be chained, filtered, mapped, and merged. //! - Sinks and streams can log their values, for easy app debugging. //! //! Postage is in *beta* quality. The functionality is implemented and has unit/integration test coverage. But it needs to be tested on more hardware, and more operating systems. mod channels; #[macro_use] mod logging; mod sink; mod stream; mod sync; pub use channels::barrier; pub use channels::broadcast; pub use channels::mpsc; pub use channels::oneshot; pub use channels::watch; pub use sink::*; pub use stream::*; #[cfg(test)] mod test;