Trait flo_stream::ToPublisherSink[−][src]

pub trait ToPublisherSink: Sized + MessagePublisher {
    fn to_sink(self) -> PublisherSink<Self>;
}

Trait that turns publishers into sinks

Required methods

fn to_sink(self) -> PublisherSink<Self>[src]

Converts this publisher into a futures Sink

Loading content...

Implementors

impl<Publisher> ToPublisherSink for Publisher where
    Publisher: Sized + MessagePublisher, [src]

Loading content...