Struct Subscription 

pub struct Subscription { /* private fields */ }

Implementations

impl Subscription

pub fn id(&self) -> u32

pub fn name(&self) -> &str

pub fn read<V>(&self) -> Option<(TimeSpec, V)>

where V: GetParameterTuple,

pub fn read_all<V>(&self) -> Option<(TimeSpec, Vec<V>)>

where V: GetParameterValue + Default,

pub fn notify<F>(&self, cb: F)

where F: Fn(&Subscription) + Send + Sync + 'static,

pub fn latest<V>(&self) -> Result<(TimeSpec, V)>

where V: GetParameterTuple,

Blocking analogue of core::Subscription::latest.

pub fn iter<V>(&self, capacity: usize) -> StreamIter<V>

where V: GetParameterTuple + Send + 'static,

Blocking iterator over the broadcast ring. Each next() call blocks on the next item via the shared runtime. The iterator ends (returns None) when the broadcast channel closes — i.e. when every Subscription clone is dropped.

Trait Implementations

impl Clone for Subscription

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.