dvb-stream

Async/tokio stream adapters over dvb-si SiDemux and dvb-t2mi T2miPump (7.0 libs).

What it does

dvb-stream wraps the synchronous dvb-si/dvb-t2mi pumps as [futures_core::Stream] implementations, quarantining tokio and futures-core away from the pure-Rust parser crates.

• SectionStream — feed any tokio::io::AsyncRead (file, TCP, UDP), receive one dvb_si::demux::SectionEvent per changed complete SI section. Events are owned (bytes::Bytes), 'static, Clone, and Send + Sync.

• T2miEventStream — same treatment for T2-MI: feed any AsyncRead, receive one dvb_t2mi::pump::T2miEvent per CRC-valid T2-MI packet. Construct with T2miEventStream::new(reader, pid) for a TS-encapsulated source, or T2miEventStream::with_pump(reader, pump) for a pre-configured pump.

Both streams perform 188-byte TS packet alignment and resync on the byte stream. No internal tasks are spawned; cancellation is simply dropping the stream.

With the udp feature (default), bind_multicast convenience constructors are provided for the dominant real-world DVB transport (UDP multicast, e.g. 239.0.0.1:5004).

dvb-stream is a std-only crate (tokio requires std).

Quickstart

use futures_util::StreamExt;
use dvb_stream::SectionStream;
use dvb_si::tables::AnyTableSection;

#[tokio::main]
async fn main() -> std::io::Result<()> {
    let f = tokio::fs::File::open("stream.ts").await?;
    let mut s = SectionStream::new(f);
    while let Some(event) = s.next().await {
        if let Ok(AnyTableSection::PatSection(pat)) = event.table_section() {
            println!("PAT ts_id={}", pat.transport_stream_id);
        }
    }
    Ok(())
}

MSRV and versioning

MSRV: 1.81 (matches the workspace). dvb-stream is versioned and released independently from the dvb-si/dvb-t2mi lockstep (0.x series), because tokio's own MSRV moves faster than the workspace pin.

Feature flags

Examples

Run with cargo run -p dvb-stream --example <name>:

• count_sections — drive the async SectionStream over an in-memory TS and count SI sections.
• stream_stats — tally table types and report demux + resync statistics.

License

MIT OR Apache-2.0.