Struct ReliableDataInputChannel 

pub struct ReliableDataInputChannel { /* private fields */ }

Handles reliable data packets, extracting the proxied application data in order.

Implementations

impl ReliableDataInputChannel

pub fn new( config: InputConfig, cipher: Option<Rc4KeyState>, now: Instant, ) -> Self

Creates a new input channel. cipher is the initial RC4 key state; pass Some(..) to enable RC4 decryption of the proxied application data, or None to pass it through unencrypted.

pub fn stats(&self) -> &DataInputStats

Returns the gathered input statistics.

pub fn take_outgoing(&mut self) -> Vec<OutgoingContextual>

Drains the outgoing acknowledgement packets accumulated so far.

pub fn take_app_data(&mut self) -> Vec<Bytes>

Drains the decoded application data buffers accumulated so far.

pub fn run_tick(&mut self, now: Instant)

Runs periodic channel logic: emits a buffered AcknowledgeAll when due.

pub fn handle_reliable_data( &mut self, data: Bytes, now: Instant, ) -> Result<(), CorruptData>

Handles a OpCode::ReliableData packet (OP code already stripped). Returns Err if the data (or any stashed fragment it releases) is malformed.

pub fn handle_reliable_data_fragment( &mut self, data: Bytes, now: Instant, ) -> Result<(), CorruptData>

Handles a OpCode::ReliableDataFragment packet (OP code already stripped). Returns Err if the fragment (or any stashed fragment it releases) is malformed.

Trait Implementations

impl Debug for ReliableDataInputChannel

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.