Struct de_net::connection::delivery::confirms::ConfirmsBuffer

pub(super) struct ConfirmsBuffer {
    oldest: Instant,
    buffer: Vec<u8>,
    flushed: usize,
}

Buffer with datagram confirmations.

Fields

oldest: Instant

buffer: Vec<u8>

flushed: usize

Implementations

impl ConfirmsBuffer

pub(super) fn new() -> Self

pub(super) fn is_empty(&self) -> bool

pub(super) fn push(&mut self, time: Instant, id: PackageId)

Pushes another datagram ID to the buffer.

pub(super) async fn send_confirms( &mut self, time: Instant, force: bool, addr: SocketAddr, datagrams: &mut Sender<OutDatagram> ) -> Result<Instant, SendError<OutDatagram>>

Send package confirmation datagrams.

Not all confirmations are sent because there is a small delay to enable grouping.

Arguments

• time - current time.

• force - if true, all pending confirmations will be sent.

• datagrams - output datagrams with the confirmations will be send to this channel.

Returns

On success, it returns an estimation of the next resend schedule time. Next schedule time is guaranteed not to happen sooner than the returned time.

fn expiration(&self) -> Option<Instant>

Returns time when the buffer expires, i.e. time when it becomes necessary to flush the buffer and send the confirmations.

fn full(&self) -> bool

fn flush(&mut self, max_size: usize) -> Option<&[u8]>

Return accumulated bytes from the buffer if it is not empty. The number of returned bytes is always smaller than max_size. This method should be called repeatedly until it returns None.