Struct WaitSet 

pub struct WaitSet { /* private fields */ }

WaitSet — Spec §2.2.2.1.6.

A WaitSet collects 0..N Arc<dyn Condition> and blocks in Self::wait until at least one triggers or a timeout is reached. Returns the list of triggered conditions.

Implementations

impl WaitSet

pub fn new() -> Self

New empty WaitSet.

pub fn attach_condition(&self, cond: Arc<dyn Condition>) -> Result<()>

Attaches a condition. Spec §2.2.2.1.6 attach_condition.

Errors

PreconditionNotMet if the internal lock is poisoned.

pub fn detach_condition(&self, cond: &Arc<dyn Condition>) -> Result<()>

Detaches a condition. Spec §2.2.2.1.6 detach_condition.

Errors

PreconditionNotMet if the internal lock is poisoned.

pub fn get_conditions(&self) -> Result<Vec<Arc<dyn Condition>>>

Current set of attached conditions.

Errors

PreconditionNotMet on lock poisoning.

pub fn wait(&self, timeout: Duration) -> Result<Vec<Arc<dyn Condition>>>

Blocks until at least one condition triggers or the timeout elapses. Returns the list of triggered conditions. Spec §2.2.2.1.6 wait.

Implementation: polling at a 1ms interval. A production- grade WaitSet would offer conditions notify hooks; that is a follow-up optimization.

Errors

• DdsError::Timeout if no condition triggers within the timeout.
• DdsError::PreconditionNotMet on lock poisoning.

pub fn notify(&self)

Wakes a blocked wait() without a trigger_value change having occurred (e.g. for shutdown).

Currently this only has an effect if the WaitSet is blocked in wait_timeout — the caller should still attach a GuardCondition so that the wakeup has a definite result.

Trait Implementations

impl Clone for WaitSet

Available on crate feature std only.

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WaitSet

Available on crate feature std only.

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

Formats the value using the given formatter.

impl Default for WaitSet

Available on crate feature std only.

fn default() -> Self

Returns the “default value” for a type.