Struct FrameQueue 

pub struct FrameQueue { /* private fields */ }

PTS-ordered staging queue for incoming frames.

Frames are pushed in any order and popped in strictly ascending PTS order. Submitting a frame with a PTS that already exists in the queue is an error.

Implementations

impl FrameQueue

pub fn new() -> Self

Create an empty queue.

pub fn push(&mut self, frame: QueuedFrame) -> CodecResult<()>

Push a frame. Returns an error if a frame with the same PTS is already queued.

pub fn pop(&mut self) -> Option<QueuedFrame>

Pop the frame with the lowest PTS, or None if the queue is empty.

pub fn peek_pts(&self) -> Option<i64>

Peek at the PTS of the next frame without removing it.

pub fn len(&self) -> usize

Number of frames currently queued.

pub fn is_empty(&self) -> bool

Returns true if no frames are queued.

pub fn drain_ordered(&mut self) -> Vec<QueuedFrame>

Drain all frames in ascending PTS order.

Trait Implementations

impl Debug for FrameQueue

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

Formats the value using the given formatter.

impl Default for FrameQueue

fn default() -> FrameQueue

Returns the “default value” for a type.