Struct PipelineProgress 

pub struct PipelineProgress { /* private fields */ }

A cloneable handle to a running pipeline’s progress. The application constructs one, passes it to run_graph_with_progress, and polls position / duration while the pipeline runs. Every clone shares one set of values.

Implementations

impl PipelineProgress

pub fn new() -> Self

A handle with no known position or duration yet.

pub fn position(&self) -> Option<u64>

Application side: the current playback position in nanoseconds (stream time), or None before the first buffer reaches a sink.

pub fn duration(&self) -> Option<u64>

Application side: the total stream duration in nanoseconds, or None if unknown (not yet reported, or a live / open-ended stream).

pub fn set_position(&self, ns: u64)

Runner side: publish the latest position (the stream time of the buffer just consumed at a sink). Latest-writer-wins, matching GStreamer answering position from the sink’s most recent buffer; a seek that rewinds simply publishes a smaller value next.

pub fn publish_duration(&self, ns: u64) -> bool

Runner side: report a source’s duration. Takes the maximum across sources (the pipeline runs until its longest stream ends). Returns true when this changed the stored duration, so the caller posts a single DurationChanged on a real change. A 0 (unknown) report is ignored.

Trait Implementations

impl Clone for PipelineProgress

fn clone(&self) -> PipelineProgress

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PipelineProgress

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

Formats the value using the given formatter.

impl Default for PipelineProgress

fn default() -> Self

Returns the “default value” for a type.