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

Converts this publisher into a futures Sink

Implementors