Trait flo_stream::PublisherSink

source · 
pub trait PublisherSink<Message>: Sink<SinkItem = Message, SinkError = ()> {
    fn subscribe(&mut self) -> Subscriber<Message>;
}
Expand description

Trait implemented by sinks that act as a publisher

Required Methods§

Creates a subscription to this publisher

Any future messages sent here will also be sent to this subscriber.

Implementors§