Trait ex_futures::sink::SinkExt
[−]
[src]
pub trait SinkExt: Sink { fn cloneable(self) -> Cloneable<Self>
where
Self: Sized, { ... } fn unsync_cloneable(self) -> UnsyncCloneable<Self>
where
Self: Sized, { ... } }
An extension of Sink
provided by futures
crate.
Any Sink
implements SinkExt
automatically.
All you are needed to do is to import SinkExt
.
use ex_futures::SinkExt;
Provided Methods
fn cloneable(self) -> Cloneable<Self> where
Self: Sized,
Self: Sized,
fn unsync_cloneable(self) -> UnsyncCloneable<Self> where
Self: Sized,
Self: Sized,
Convert any kind of sink into "cloneable" sink but unsync. That is kind like mpsc.
Examples
use ex_futures::SinkExt; let (tx, rx) = ::futures::sync::mpsc::channel::<usize>(42); let cloneable_sink = tx.unsync_cloneable(); // Convert "tx" into cloneable. let cloneable_sink2 = cloneable_sink.clone(); // Now you can clone it.
Implementors
impl<S> SinkExt for S where
S: Sink,