Struct atomx::signal::source::Source

pub struct Source<T: Send + Default> { /* private fields */ }

Implementations

impl<T> Source<T>

where T: Clone + Sync + Default + Send,

pub fn from(value: T) -> Self

Create a new source from a given value.

pub fn send(&mut self, data: &T) -> State

Modify the current data and publish the changes to the sinks. The data will be cloned once.

pub fn modify(&mut self, closure: &mut dyn FnMut(&mut T)) -> State

Modify the current data with zero copy and publish the changes to the sinks.

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

Access the current data without publishing the change to the sinks.

pub fn sink_count(&self) -> u32

Returns the number of current sinks connected to the source.

pub fn sink(&self) -> Sink<T>

Return a new sink form source.