Struct ChunkDecoder 

pub struct ChunkDecoder { /* private fields */ }

Chunk stream decoder

Handles chunk demultiplexing and message reassembly.

Implementations

impl ChunkDecoder

pub fn new() -> Self

Create a new decoder with default chunk size

pub fn set_chunk_size(&mut self, size: u32)

Set the chunk size (called when receiving SetChunkSize message)

pub fn chunk_size(&self) -> u32

Get current chunk size

pub fn decode(&mut self, buf: &mut BytesMut) -> Result<Option<RtmpChunk>>

Try to decode a complete message from the buffer

Returns Ok(Some(chunk)) if a complete message was decoded, Ok(None) if more data is needed, or Err on protocol error.

pub fn abort(&mut self, csid: u32)

Abort a message on a chunk stream (when receiving Abort message)

Trait Implementations

impl Default for ChunkDecoder

fn default() -> Self

Returns the “default value” for a type.