future_pubsub
A tokio future based publish-subscribe channel.
For now, this crate provides
- unsync unbounded publish subscribe channel
- unsync unbounded cloneable stream
And will provide in future
- unsync bounded publish subscribe channel
- sync unbounded publish subscribe channel
- sync bounded publish subscribe channel
- unsync bounded cloneable stream
- sync unbounded cloneable stream
- sync bounded cloneable stream
How to use
Publish-Subscribe channel
An usage is almost same with futures::unsync::mpsc::unbounded
.
use unbounded;
Cloneable stream
use into_cloneable;