Struct SectionReassembler 

pub struct SectionReassembler { /* private fields */ }

Reassembles PSI/SI sections from TS packets on a single PID.

Feed each TS packet’s payload with feed. Complete sections are appended to an internal queue; drain them with pop_section.

Implementations

impl SectionReassembler

pub fn feed(&mut self, payload: &[u8], pusi: bool)

Feed a TS payload and whether its packet had PUSI set.

Extracts complete SI sections into the internal queue. A single call can produce zero, one, or several sections — a payload may concatenate multiple complete sections after the pointer_field (EN 300 468 §5.1.4; common on EMM PIDs). Drain with a while let Some(s) = r.pop_section() loop, not a single if let.

Examples found in repository

examples/demux.rs (line 37)

fn main() {
    let pkt = TsPacket::parse(&PAT_PACKET).expect("hardcoded packet must parse");
    println!(
        "TS packet: pid=0x{:04X} pusi={} has_payload={}",
        pkt.header.pid, pkt.header.pusi, pkt.header.has_payload
    );

    let mut reasm = SectionReassembler::default();

    if let Some(payload) = pkt.payload {
        reasm.feed(payload, pkt.header.pusi);
    }

    while let Some(section) = reasm.pop_section() {
        println!(
            "section: {} bytes, table_id=0x{:02X}",
            section.len(),
            section[0]
        );
        // The PAT section bytes: table_id=0x00, transport_stream_id at bytes 3-4.
        if section.len() >= 5 {
            let ts_id = u16::from_be_bytes([section[3], section[4]]);
            println!("  transport_stream_id={}", ts_id);
        }
    }
}

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

Pop one complete section. Returns None when the queue is empty.

Examples found in repository

examples/demux.rs (line 40)

fn main() {
    let pkt = TsPacket::parse(&PAT_PACKET).expect("hardcoded packet must parse");
    println!(
        "TS packet: pid=0x{:04X} pusi={} has_payload={}",
        pkt.header.pid, pkt.header.pusi, pkt.header.has_payload
    );

    let mut reasm = SectionReassembler::default();

    if let Some(payload) = pkt.payload {
        reasm.feed(payload, pkt.header.pusi);
    }

    while let Some(section) = reasm.pop_section() {
        println!(
            "section: {} bytes, table_id=0x{:02X}",
            section.len(),
            section[0]
        );
        // The PAT section bytes: table_id=0x00, transport_stream_id at bytes 3-4.
        if section.len() >= 5 {
            let ts_id = u16::from_be_bytes([section[3], section[4]]);
            println!("  transport_stream_id={}", ts_id);
        }
    }
}

pub fn len(&self) -> usize

Number of bytes currently buffered (incomplete section).

pub fn is_empty(&self) -> bool

True if no bytes are currently buffered.

Trait Implementations

impl Default for SectionReassembler

fn default() -> SectionReassembler

Returns the “default value” for a type.