Struct ReadCondition 

pub struct ReadCondition { /* private fields */ }

ReadCondition — Spec §2.2.2.5.8 / §2.2.4.5 trigger state.

A ReadCondition is bound to a DataReader and triggers true when the reader holds samples that match all three masks (sample_state_mask, view_state_mask, instance_state_mask).

Design: the trigger logic itself (the actual “does the reader have samples with these masks?” query) is injected by the caller as a closure, because the DataReader sample cache cannot be queried in an object-safe way without further infrastructure changes. The DCPS API consumer (usually DataReader::create_readcondition) provides the closure in the form (sm, vm, im) -> bool.

Implementations

impl ReadCondition

pub fn new<F>( sample_state_mask: u32, view_state_mask: u32, instance_state_mask: u32, trigger: F, ) -> Arc<Self>

where F: Fn(u32, u32, u32) -> bool + Send + Sync + 'static,

Constructor with a trigger closure.

pub fn get_sample_state_mask(&self) -> u32

Spec §2.2.2.5.8 get_sample_state_mask.

pub fn get_view_state_mask(&self) -> u32

Spec §2.2.2.5.8 get_view_state_mask.

pub fn get_instance_state_mask(&self) -> u32

Spec §2.2.2.5.8 get_instance_state_mask.

Trait Implementations

impl Condition for ReadCondition

fn get_trigger_value(&self) -> bool

True if the event of this condition is currently pending. Spec §2.2.2.1.6 get_trigger_value.

impl Debug for ReadCondition

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

Formats the value using the given formatter.