Struct Subscribable 

pub struct Subscribable<T: Copy> { /* private fields */ }

Clone-able handle for spawning Subscribers.

Send this to other threads and call subscribe to create independent consumers.

Implementations

impl<T: Copy> Subscribable<T>

pub fn subscribe(&self) -> Subscriber<T>

Create a subscriber that will see only future messages.

pub fn subscribe_from_oldest(&self) -> Subscriber<T>

Create a subscriber starting from the oldest available message still in the ring (or 0 if nothing published yet).

Trait Implementations

impl<T: Copy> Clone for Subscribable<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Copy + Send> Send for Subscribable<T>

impl<T: Copy + Send> Sync for Subscribable<T>