Struct T2miEventStream 

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

Async Stream of T2miEvents from a raw TS byte source.

Feed any tokio::io::AsyncRead byte source and receive one T2miEvent per complete, CRC-valid T2-MI packet.

The adapter performs 188-byte TS packet alignment using the same resync logic as SectionStream (see crate::resync).

Cancellation

Drop the stream. No internal tasks are spawned.

Implementations

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

pub fn new(reader: R, pid: u16) -> Self

Create a T2miEventStream from a TS-encapsulated source on pid.

pid is the 13-bit T2-MI PID from the PMT (e.g. 0x0006).

pub fn with_pump(reader: R, pump: T2miPump) -> Self

Create a T2miEventStream with an already-constructed T2miPump.

pub fn stats(&self) -> Stats

Access the underlying pump statistics.

pub fn resync_stats(&self) -> ResyncStats

Access the resync statistics.

impl T2miEventStream<UdpReader>

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

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

Bind a UDP socket to bind_addr and join multicast_addr.

pid is the 13-bit T2-MI PID from the PMT.

Errors

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

Trait Implementations

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

type Item = T2miEvent

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.