Struct de_net::connection::delivery::DeliveryHandler

pub(crate) struct DeliveryHandler {
    book: Arc<Mutex<ConnectionBook<ConnDeliveryHandler>>>,
}

Fields

book: Arc<Mutex<ConnectionBook<ConnDeliveryHandler>>>

Implementations

impl DeliveryHandler

pub(crate) fn new() -> Self

pub(crate) async fn lock(&mut self) -> ReceiveHandlerGuard<'_>

pub(crate) async fn send_confirms( &mut self, time: Instant, force: bool, 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.

pub(crate) async fn clean(&mut self, time: Instant)

Trait Implementations

impl Clone for DeliveryHandler

fn clone(&self) -> DeliveryHandler

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.