futures_ext
An extension of futures
.
For now, this crate provides
- unsync unbounded publish subscribe channel
- unsync unbounded cloneable stream/sink
And will provide in future
- unsync bounded publish subscribe channel
- sync unbounded publish subscribe channel
- sync bounded publish subscribe channel
- unsync bounded cloneable stream/sink
- sync unbounded cloneable stream/sink
- sync bounded cloneable stream/sink
How to use
Publish-Subscribe channel
An usage is almost same with futures::unsync::mpsc::unbounded
.
use unbounded;
Cloneable stream/sink
use StreamExt;