Struct FanoutOutput 

pub struct FanoutOutput { /* private fields */ }

A StreamOutput wrapper that fans frames out to multiple targets.

Create with FanoutOutput::new, passing a Vec<Box<dyn StreamOutput>>. Every call to push_video, push_audio, or finish is forwarded to all targets in order.

Failure behaviour

When one or more targets return an error, the remaining targets still receive the frame. All errors are collected and returned as a single StreamError::FanoutFailure.

Implementations

impl FanoutOutput

pub fn new(targets: Vec<Box<dyn StreamOutput>>) -> Self

Create a new fanout output that delivers frames to all targets.

Example

use ff_stream::{FanoutOutput, LiveHlsOutput, StreamOutput};

let out = FanoutOutput::new(vec![Box::new(hls_output)]);

Trait Implementations

impl StreamOutput for FanoutOutput

fn push_video(&mut self, frame: &VideoFrame) -> Result<(), StreamError>

Push one video frame into the stream.

fn push_audio(&mut self, frame: &AudioFrame) -> Result<(), StreamError>

Push one audio frame into the stream.

fn finish(self: Box<Self>) -> Result<(), StreamError>

Flush all buffered data and close the output.