Struct PusiReassembler 

pub struct PusiReassembler { /* private fields */ }

Generic PUSI-delimited payload reassembler.

Accumulates payload bytes across consecutive TS packets sharing the same PID, using payload_unit_start_indicator to delimit unit boundaries.

Example

let mut reassembler = PusiReassembler::new(0x0004);

// Feed pusi=true first packet
if let Some(unit) = reassembler.push(0x0004, true, &first_payload) {
    // unit is complete (would only happen if a second PUSI follows)
}

// Feed continuation
reassembler.push(0x0004, false, &cont_payload);

// Drain the final unit
if let Some(unit) = reassembler.flush() {
    // process complete unit
}

Implementations

impl PusiReassembler

pub fn new(pid: u16) -> Self

Create a new reassembler for the given pid.

pub fn push(&mut self, pid: u16, pusi: bool, payload: &[u8]) -> Option<Vec<u8>>

Feed one TS packet’s (pid, payload_unit_start_indicator, payload bytes).

Packets whose pid != self.pid are silently ignored (returns None).

PUSI semantics: When pusi == true, the packet marks the start of a new unit. If a unit was already in progress (i.e. a prior PUSI-start was never closed by a following PUSI), the in-progress unit is complete — it is returned as Some(unit_bytes), and a fresh unit begins with this packet’s payload.

When pusi == false, the payload is appended to the in-progress unit.

Returns Some(Vec<u8>) when a completed unit is emitted; None otherwise.

pub fn flush(&mut self) -> Option<Vec<u8>>

Return any in-progress (final) unit; the caller drains this at end of the PID’s data (the last real box has no following PUSI to close it).

Returns None when no data has been accumulated.

Trait Implementations

impl Clone for PusiReassembler

fn clone(&self) -> PusiReassembler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PusiReassembler

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

Formats the value using the given formatter.