Struct VolatileSecureMessageReader 

pub struct VolatileSecureMessageReader { /* private fields */ }

Reader for DCPSParticipantVolatileMessageSecure.

Implementations

impl VolatileSecureMessageReader

pub fn new(participant_prefix: GuidPrefix, vendor_id: VendorId) -> Self

Creates a reader for the local participant.

pub fn guid(&self) -> Guid

GUID of the reader.

pub fn writer_proxy_count(&self) -> usize

Number of registered writer proxies.

pub fn inner(&self) -> &ReliableReader

Read-only access to the ReliableReader (tests/diagnostics).

pub fn add_writer_proxy(&mut self, proxy: WriterProxy)

Adds a writer proxy.

pub fn remove_writer_proxy(&mut self, guid: Guid) -> Option<WriterProxy>

Removes a writer proxy.

pub fn handle_data( &mut self, source_prefix: GuidPrefix, data: &DataSubmessage, ) -> SecurityResult<Vec<ParticipantGenericMessage>>

Processes an incoming DATA submessage and returns decoded generic messages.

Errors

BadArgument if the encapsulation/CDR decode fails.

pub fn handle_data_frag( &mut self, source_prefix: GuidPrefix, df: &DataFragSubmessage, now: Duration, ) -> SecurityResult<Vec<ParticipantGenericMessage>>

Process DATA_FRAG.

Errors

see handle_data.

pub fn handle_gap( &mut self, source_prefix: GuidPrefix, gap: &GapSubmessage, ) -> SecurityResult<Vec<ParticipantGenericMessage>>

Process GAP.

Errors

see handle_data.

pub fn handle_heartbeat( &mut self, source_prefix: GuidPrefix, hb: &HeartbeatSubmessage, now: Duration, )

HEARTBEAT verarbeiten.

pub fn tick_outbound( &mut self, now: Duration, ) -> Result<Vec<OutboundDatagram>, WireError>

Tick (ACKNACK / NACK_FRAG outbound).

Errors

Wire encode errors.

Trait Implementations

impl Debug for VolatileSecureMessageReader

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

Formats the value using the given formatter.