Trait flo_stream::PubSubSpawn
source · pub trait PubSubSpawn<Message: Clone> {
fn subscribe(&mut self) -> Subscriber<Message>;
}
Required Methods§
sourcefn subscribe(&mut self) -> Subscriber<Message>
fn subscribe(&mut self) -> Subscriber<Message>
Creates a new subscriber for this publisher
Implementations on Foreign Types§
source§impl<Message: Clone, S: PublisherSink<Message>> PubSubSpawn<Message> for Spawn<S>
impl<Message: Clone, S: PublisherSink<Message>> PubSubSpawn<Message> for Spawn<S>
For convenience, makes it possible to subscribe() to spawned publishers without having to call get_mut()