Struct atomx::signal::sync::sink::Sink

pub struct Sink<T>
where
    T: Clone + Sync + Send + Default,
{ /* private fields */ }

Implementations

impl<T> Sink<T>

where T: Clone + Sync + Send + Default,

pub fn from(source: &Source<T>) -> Self

Creates a new Sink from the given Source. This is the only way to create a Sink. That’s necessary to guaranty that both share the same sync property.

pub fn receive(&self) -> T

Returns a copy of the received signal value. This is especially useful for small or primitive types. If the signal data is to expansive to copy have a look at [process].

pub fn process(&self, closure: &mut dyn FnMut(&T))

In contrast to [receive] this function allows the consumer to directly access the data via an immutable reference given by a closure. This could drastically reduce memory usage, but creates back pressure onto the sender if processing takes to much time (even if not synced).

pub fn changed(&self) -> bool

Check if source have changed the signal, since last acknowledge.

Trait Implementations

impl<T> Clone for Sink<T>

where T: Clone + Sync + Send + Default,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Default for Sink<T>

where T: Clone + Sync + Send + Default + Default,

fn default() -> Sink<T>

Returns the “default value” for a type.