Struct MultiTrackExecutor 

pub struct MultiTrackExecutor<M: Muxer> { /* private fields */ }

Frame-level multi-track decode → filter → encode executor with DTS-ordered muxing.

Usage

use oximedia_transcode::multi_track::{MultiTrackExecutor, PerTrack};
use oximedia_transcode::pipeline_context::{FilterGraph, Frame};

// Supply concrete FrameDecoder / FrameEncoder implementations:
let mut executor = MultiTrackExecutor::new(muxer);
executor.add_track(PerTrack::new(0, decoder0, FilterGraph::new(), encoder0));
executor.add_track(PerTrack::new(1, decoder1, FilterGraph::new(), encoder1));
let stats = executor.execute(&streams).await?;

Implementations

impl<M: Muxer> MultiTrackExecutor<M>

pub fn new(muxer: M) -> Self

Creates a new executor wrapping muxer.

Tracks must be added with add_track before calling execute or step.

pub fn add_track(&mut self, track: PerTrack)

Adds a PerTrack to the executor.

pub fn set_flush_interval(&mut self, n: u64)

Overrides the heap flush interval (default: 30 steps).

pub fn muxer(&self) -> &M

Returns a shared reference to the inner muxer.

pub fn into_muxer(self) -> M

Consumes the executor and returns the inner muxer.

pub fn stats(&self) -> &MultiTrackStats

Returns the accumulated execution statistics.

pub async fn step(&mut self) -> Result<bool>

Perform one step of the pipeline: attempt to decode one frame from every active track, filter and encode it, then push the result onto the DTS heap.

Periodically drains the heap to the muxer based on the minimum active DTS (safe-drain strategy).

Returns true if at least one track produced an encoded packet this step, false when all tracks are exhausted.

Errors

Propagates errors from the filter graph, encoder, or muxer.

pub async fn execute( &mut self, streams: &[StreamInfo], ) -> Result<MultiTrackStats>

Execute the full pipeline end-to-end.

1. Registers streams with the muxer and writes the header.
2. Calls step in a loop until all tracks are exhausted.
3. Flushes each track’s encoder.
4. Drains the remaining heap to the muxer in DTS order.
5. Writes the muxer trailer.

Returns accumulated MultiTrackStats.

Errors

Returns an error if any stage (filter, encode, mux header/packet/trailer) fails.