Struct Reassembler 

pub struct Reassembler { /* private fields */ }

Zero-copy block assembly state machine.

Implementations

impl Reassembler

pub fn new(packet_payload: usize, stats: StreamStatsAccumulator) -> Self

pub fn start_block( &mut self, block_id: u16, expected_packets: usize, buffer: BytesMut, )

Start a new block, evicting the previous one when necessary.

pub fn push_packet(&mut self, packet_id: usize, payload: &[u8])

Insert a packet belonging to the active block.

pub fn finish_block(&mut self) -> Option<Bytes>

Attempt to finish the current block.

Trait Implementations

impl Debug for Reassembler

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

Formats the value using the given formatter.