Module future_pubsub::unsync [] [src]

Structs

Cloneable

A cloneable stream being created by into_cloneable function. You can clone this stream as you want. Each cloned stream is also cloneable.

SendError
UnboundedReceiver

The receiving end of an unbounded channel. This is created by the unbounded function.

UnboundedSender

The transmission end of an unbounded channel. This is created by the unbounded function.

Functions

into_cloneable

Convert given stream into Cloneable. Cloneable is able to be cloned.

unbounded

Returns unbounded sender and receiver. This function is like another hand of futures::unsync::mpsc::unbounded but every item being treated need to implement Clone trait.