Struct MpegVideoPipeline 

pub struct MpegVideoPipeline { /* private fields */ }

High-level convenience wrapper: demux container bytes and decode MPEG-1/2 video frames.

This type is designed for low-overhead integration:

• You can reuse a single pipeline instance across the whole stream.
• Use push_with()/flush_with() to avoid collecting frames into intermediate vectors.

Implementations

impl MpegVideoPipeline

pub fn new() -> Self

pub fn decoder_mut(&mut self) -> &mut Decoder

pub fn demuxer_mut(&mut self) -> &mut Demuxer

pub fn push_with<F>( &mut self, data: &[u8], pts_90k: Option<i64>, on_frame: F, ) -> Result<()>

where F: FnMut(Arc<Frame>),

Feed container bytes and invoke on_frame for each decoded frame.

pts_90k is optional chunk-level PTS in 90 kHz timebase. When demuxing TS/PS, packet-level PTS from PES headers takes precedence.

pub fn flush_with<F>(&mut self, on_frame: F) -> Result<()>

where F: FnMut(Arc<Frame>),

Flush delayed frames and invoke on_frame for each of them.

Trait Implementations

impl Debug for MpegVideoPipeline

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

Formats the value using the given formatter.

impl Default for MpegVideoPipeline

fn default() -> MpegVideoPipeline

Returns the “default value” for a type.