Trait flo_stream::ToPublisherSink [−][src]
pub trait ToPublisherSink: Sized + MessagePublisher {
fn to_sink(self) -> PublisherSink<Self>;
}
Expand description
Trait that turns publishers into sinks
Required methods
fn to_sink(self) -> PublisherSink<Self>
fn to_sink(self) -> PublisherSink<Self>
Converts this publisher into a futures Sink