Struct StatelessMessageWriter 

pub struct StatelessMessageWriter { /* private fields */ }

Stateless message writer (Spec §7.4.4 + §10.3.4).

Maintains multi-reader fan-out for the BUILTIN_PARTICIPANT_STATELESS_MESSAGE_WRITER endpoint. Each write() produces one OutboundDatagram per registered ReaderProxy — no cache, no resend, no HEARTBEAT (stateless = no receive status).

Implementations

impl StatelessMessageWriter

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

Creates a writer for the local participant.

pub fn guid(&self) -> Guid

GUID of the writer.

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

Read-only slice of the registered reader proxies.

pub fn reader_proxy_count(&self) -> usize

Number of registered reader proxies.

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

Adds a reader proxy (idempotent: same GUID overwrites).

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

Removes a reader proxy. Returns it if present.

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

Sends a ParticipantGenericMessage to all reader proxies.

Returns one datagram per proxy (or empty if none are registered).

Errors

WireError::ValueOutOfRange on sequence-number overflow or WireError::* from the DATA encoding pipeline.

Trait Implementations

impl Debug for StatelessMessageWriter

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

Formats the value using the given formatter.