Struct SedpSubscriptionsReader 

pub struct SedpSubscriptionsReader { /* private fields */ }

Reader fuer SEDP-Subscriptions (feste EntityId EntityId::SEDP_BUILTIN_SUBSCRIPTIONS_READER).

Implementations

impl SedpSubscriptionsReader

pub fn new( participant_prefix: GuidPrefix, vendor_id: VendorId, remote_writer_prefix: GuidPrefix, remote_metatraffic_unicast: Vec<Locator>, ) -> Self

Erzeugt einen SEDP-Subscriptions-Reader.

pub fn guid(&self) -> Guid

GUID.

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

Fuegt einen weiteren Remote-SEDP-Writer als Proxy hinzu.

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

Entfernt einen Remote-Writer.

pub fn handle_data( &mut self, data: &DataSubmessage, ) -> Result<Vec<SubscriptionBuiltinTopicData>, SedpReaderError>

Verarbeitet eine DATA-Submessage.

Errors

siehe SedpPublicationsReader::handle_data.

pub fn handle_data_frag( &mut self, df: &DataFragSubmessage, now: Duration, ) -> Result<Vec<SubscriptionBuiltinTopicData>, SedpReaderError>

DATA_FRAG.

Errors

siehe handle_data.

pub fn handle_gap( &mut self, gap: &GapSubmessage, ) -> Result<Vec<SubscriptionBuiltinTopicData>, SedpReaderError>

GAP.

Errors

siehe handle_data.

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

HEARTBEAT.

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

Tick.

Errors

Wire-Encode-Fehler.

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

Tick mit Ziel-Locators.

Errors

Wire-Encode-Fehler.

pub fn inner(&self) -> &ReliableReader

Read-only-Zugriff.

Trait Implementations

impl Debug for SedpSubscriptionsReader

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

Formats the value using the given formatter.