Struct ReliableEndpoint 

pub struct ReliableEndpoint { /* private fields */ }

The reliable channel to a single peer. Pure: drive it with send, on_datagram, and on_tick, moving the returned frames over the mesh yourself.

Implementations

impl ReliableEndpoint

pub fn new(rto_ms: u64, max_attempts: u32) -> ReliableEndpoint

A channel with explicit retransmit timeout and attempt cap.

pub fn send(&mut self, payload: &[u8], now_ms: u64) -> Vec<u8>

Queue payload for reliable delivery and return the DATA frame to send now. The frame is buffered for retransmission until the peer acknowledges it (see on_tick).

pub fn pending(&self) -> usize

Number of datagrams still awaiting acknowledgement.

pub fn on_datagram(&mut self, frame: &[u8], _now_ms: u64) -> Inbound

Process one inbound wire frame. A DATA frame is deduplicated and (if new) its payload is delivered; either way an ACK is returned so the sender stops retransmitting. An ACK frame clears the matching unacked datagram. Malformed frames are ignored.

pub fn on_tick(&mut self, now_ms: u64) -> (Vec<Vec<u8>>, Vec<u32>)

Retransmit any datagram unacknowledged for longer than the RTO. Returns the frames to resend. Datagrams that exceed the attempt cap are given up on and reported in the second element.

Trait Implementations

impl Default for ReliableEndpoint

fn default() -> Self

Returns the “default value” for a type.