Struct MicroReader 

pub struct MicroReader { /* private fields */ }

MicroReader - DDS DataReader

Receives data samples from a topic.

Design

• BEST_EFFORT QoS (no acknowledgments)
• No history cache (process immediately)
• Fixed-size receive buffer

Example

let reader = MicroReader::new(
    participant.guid_prefix(),
    reader_entity_id,
    "Temperature",
);

// Read sample
if let Some(sample) = reader.read(participant.transport_mut())? {
    let mut decoder = CdrDecoder::new(sample.payload);
    let temp: f32 = decoder.decode_f32()?;
    let timestamp: i64 = decoder.decode_i64()?;
}

Implementations

impl MicroReader

pub fn new( guid_prefix: GuidPrefix, entity_id: EntityId, topic_name: &str, ) -> Result<Self>

Create a new reader

Arguments

• guid_prefix - Participant’s GUID prefix
• entity_id - Reader’s entity ID
• topic_name - Topic name (max 63 chars)

pub const fn guid(&self) -> GUID

Get reader GUID

pub fn topic_name(&self) -> &str

Get topic name

pub fn read<T: Transport>( &mut self, transport: &mut T, ) -> Result<Option<Sample<'_>>>

Read a sample (non-blocking)

Returns None if no sample available.

Trait Implementations

impl Debug for MicroReader

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

Formats the value using the given formatter.

impl PartialEq for MicroReader

fn eq(&self, other: &MicroReader) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for MicroReader