Struct de_net::connection::dispatch::DispatchHandler

pub(crate) struct DispatchHandler {
    book: Arc<Mutex<ConnectionBook<ConnDispatchHandler>>>,
}

Fields

book: Arc<Mutex<ConnectionBook<ConnDispatchHandler>>>

Implementations

impl DispatchHandler

pub(crate) fn new() -> Self

pub(crate) async fn next_package_id( &mut self, time: Instant, addr: SocketAddr ) -> PackageId

Returns ID to be given to a to-be-send package.

It is assumed that this is called exactly once before each reliably send package and that all generated IDs are used.

pub(crate) async fn sent( &mut self, time: Instant, addr: SocketAddr, header: PackageHeader, data: &[u8] )

Panics

• If the package is already registered as sent.

• If the data are longer than MAX_PACKAGE_SIZE.

pub(crate) async fn confirmed( &mut self, time: Instant, addr: SocketAddr, data: &[u8] )

Processes data with package confirmations.

The data encode IDs of delivered (and confirmed) packages so that they can be forgotten.

pub(crate) async fn resend( &mut self, time: Instant, buf: &mut [u8], datagrams: &mut Sender<OutDatagram> ) -> Result<ResendResult, SendError<OutDatagram>>

Re-send all packages already due for re-sending.

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

Trait Implementations

impl Clone for DispatchHandler

fn clone(&self) -> DispatchHandler

Returns a copy of the value.

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

Performs copy-assignment from source.