Trait flo_stream::PubSubSpawn

pub trait PubSubSpawn<Message: Clone> {
    fn subscribe(&mut self) -> Subscriber<Message>;
}

Required Methods

fn subscribe(&mut self) -> Subscriber<Message>

Creates a new subscriber for this publisher

Implementations on Foreign Types

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()

fn subscribe(&mut self) -> Subscriber<Message>

Implementors