Struct SrsppSender 

pub struct SrsppSender<L: NetworkWrite + NetworkRead<Error = <L as NetworkWrite>::Error>, P: RtoPolicy, const WIN: usize, const BUF: usize, const MTU: usize> { /* private fields */ }

Async srspp sender.

Sends messages reliably over the link, handling segmentation and retransmission. Receives ACKs from the remote receiver.

Implementations

impl<L: NetworkWrite + NetworkRead<Error = <L as NetworkWrite>::Error>, P: RtoPolicy, const WIN: usize, const BUF: usize, const MTU: usize> SrsppSender<L, P, WIN, BUF, MTU>

pub fn new( config: SenderConfig, link: L, rto_policy: P, ticks_per_sec: u32, ) -> Self

Create a new sender.

pub async fn send( &mut self, target: Address, data: &(impl IntoBytes + Immutable + ?Sized), ) -> Result<(), SrsppError>

Send a message.

The message is segmented if necessary and queued for transmission. This returns when all packets have been transmitted (but not necessarily ACKed).

For guaranteed delivery, call flush() after sending.

pub async fn flush(&mut self) -> Result<(), SrsppError>

Wait for all sent data to be acknowledged.

pub async fn poll(&mut self) -> Result<(), SrsppError>

Poll for incoming ACKs and handle timeouts.

Call this periodically if you want to process ACKs without blocking on flush.

pub fn is_idle(&self) -> bool

Check if all data has been acknowledged.

pub fn available_bytes(&self) -> usize

Available buffer space in bytes.