Struct StatelessMessageWriter 

pub struct StatelessMessageWriter { /* private fields */ }

Stateless-Message-Writer (Spec §7.4.4 + §10.3.4).

Pflegt Multi-Reader-Fan-out fuer den BUILTIN_PARTICIPANT_STATELESS_MESSAGE_WRITER-Endpoint. Jedes write() erzeugt pro registriertem ReaderProxy ein OutboundDatagram — kein Cache, kein Resend, kein HEARTBEAT (Stateless = kein Empfangs-Status).

Implementations

impl StatelessMessageWriter

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

Erzeugt einen Writer fuer den lokalen Participant.

pub fn guid(&self) -> Guid

GUID des Writers.

pub fn reader_proxies(&self) -> &[ReaderProxy]

Read-only-Slice der registrierten Reader-Proxies.

pub fn reader_proxy_count(&self) -> usize

Anzahl registrierter Reader-Proxies.

pub fn add_reader_proxy(&mut self, proxy: ReaderProxy)

Fuegt einen Reader-Proxy hinzu (idempotent: gleiche GUID ueberschreibt).

pub fn remove_reader_proxy(&mut self, guid: Guid) -> Option<ReaderProxy>

Entfernt einen Reader-Proxy. Liefert ihn zurueck, falls vorhanden.

pub fn write( &mut self, msg: &ParticipantGenericMessage, ) -> Result<Vec<OutboundDatagram>, WireError>

Sendet eine ParticipantGenericMessage an alle Reader-Proxies.

Liefert ein Datagram pro Proxy (oder leer, wenn keine registriert sind).

Errors

WireError::ValueOutOfRange bei Sequence-Number-Overflow oder WireError::* aus der DATA-Encoding-Pipeline.

Trait Implementations

impl Debug for StatelessMessageWriter

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

Formats the value using the given formatter.