Struct SectionStream 

pub struct SectionStream<R> { /* private fields */ }

Async Stream of SectionEvents from a raw TS byte source.

Feed any tokio::io::AsyncRead byte source (file, TCP socket, UDP socket) and receive one SectionEvent per changed complete SI section.

Internally the adapter:

1. Reads bytes from reader into a fixed-size buffer.
2. Resyncs on the first 0x47 sync byte (via crate::resync::resync).
3. Feeds each aligned 188-byte packet into the owned SiDemux.
4. Yields events from the demux’s output queue before reading more.

Owned events

SectionEvent already owns its section bytes via bytes::Bytes and is 'static, Clone, and Send + Sync. No additional wrapping is needed.

Cancellation

Drop the stream. No internal tasks are spawned.

Implementations

impl<R: AsyncRead + Unpin> SectionStream<R>

pub fn new(reader: R) -> Self

Create a SectionStream with the default SiDemux configuration (all standard DVB/SI PIDs, PAT-follow enabled, version gating).

pub fn with_builder(reader: R, builder: SiDemuxBuilder) -> Self

Create a SectionStream with a custom SiDemuxBuilder.

pub fn with_demux(reader: R, demux: SiDemux) -> Self

Create a SectionStream with an already-constructed SiDemux.

pub fn stats(&self) -> Stats

Access the underlying demux statistics.

pub fn resync_stats(&self) -> ResyncStats

Access the resync statistics.

impl SectionStream<UdpReader>

UDP/multicast convenience constructor — enabled by the udp feature.

pub async fn bind_multicast( bind_addr: SocketAddrV4, multicast_addr: Ipv4Addr, ) -> Result<Self>

Bind a UDP socket to bind_addr and join multicast_addr.

Typical DVB multicast delivery uses addresses like 239.0.0.1:5004. The returned SectionStream reads one UDP datagram per poll_next cycle from the socket (treated as a raw TS byte source).

Errors

Returns a std::io::Error if binding or joining the multicast group fails.

Trait Implementations

impl<R: AsyncRead + Unpin> Stream for SectionStream<R>

type Item = SectionEvent

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.