Struct OutputSubject 

pub struct OutputSubject<M> { /* private fields */ }

Holds created OutputTrackers and emits data to all known trackers.

This is the non-threadsafe variant.

New OutputTrackers can be created by calling the create_tracker() function.

The emit(data) function emits data to all trackers, that have been created for this subject and are not stopped yet.

Implementations

impl<M> OutputSubject<M>

pub fn new() -> Self

Constructs a new OutputSubject.

A new subject does nothing unless one or more trackers have been created.

impl<M> OutputSubject<M>

where M: Clone,

pub fn create_tracker(&self) -> Result<OutputTracker<M>, Error>

Creates a new OutputTracker and registers it to be ready to track emitted data.

pub fn emit(&self, data: M) -> Result<(), Error>

Emits given data to all active OutputTrackers.

Stopped OutputTrackers do not receive any emitted data.

Trait Implementations

impl<M: Clone> Clone for OutputSubject<M>

fn clone(&self) -> OutputSubject<M>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<M: Debug> Debug for OutputSubject<M>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<M: Default> Default for OutputSubject<M>

fn default() -> OutputSubject<M>

Returns the “default value” for a type.