Struct ChunkStream 

pub struct ChunkStream {
    pub csid: u32,
    pub chunk_size: u32,
    pub type0_timestamp: u32,
    pub type0_msg_length: u32,
    pub type0_msg_type_id: u8,
    pub type0_msg_stream_id: u32,
    pub type0_ext_ts: bool,
    pub last_delta: u32,
    pub reassembly_bytes_read: u32,
    pub reassembly_buf: Buffer,
    pub last_payload: Vec<u8>,
    pub in_use: bool,
    /* private fields */
}

Per-chunk-stream state.

Fields

csid: u32

chunk_size: u32

peer’s chunk size (SetChunkSize)

type0_timestamp: u32

running timestamp for this chunk stream

type0_msg_length: u32

type0_msg_type_id: u8

type0_msg_stream_id: u32

type0_ext_ts: bool

current message uses extended timestamps

last_delta: u32

The most recent fmt=1/2 timestamp delta applied on this CSID. A new message that starts with fmt=3 (reusing the prior header entirely) implicitly repeats this same delta per RTMP spec 5.3.1.3.

reassembly_bytes_read: u32

bytes read so far for current message

reassembly_buf: Buffer

buffer for reassembling partial messages

last_payload: Vec<u8>

Last completed payload on this CSID. Copied before reassembly_buf is reset/shrunk so callers can read via the returned pointer safely.

in_use: bool

Implementations

impl ChunkStream

pub fn reset(&mut self, default_chunk_size: u32)

Reset stream state and release retained payload/reassembly allocations.

Trait Implementations

impl Debug for ChunkStream

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

Formats the value using the given formatter.

impl Default for ChunkStream

fn default() -> Self

Returns the “default value” for a type.