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§
sourcefn subscribe(&mut self) -> Subscriber<Message>
fn subscribe(&mut self) -> Subscriber<Message>
Creates a subscription to this publisher
Any future messages sent here will also be sent to this subscriber.