Struct RecordingSink 

pub struct RecordingSink<S: StorageBackend> { /* private fields */ }

Available on crate feature record only.

Records a stream to sequential objects under a storage prefix.

Each object spans up to chunk_duration seconds (cut on the first keyframe at or past the boundary, so chunks remain independently decodable).

Implementations

impl<S: StorageBackend> RecordingSink<S>

pub fn new( storage: S, prefix: impl Into<String>, chunk_duration_secs: u64, ) -> Self

New recorder writing chunk_duration-second objects under prefix.

Trait Implementations

impl<S: StorageBackend> MediaSink for RecordingSink<S>

fn send_frame<'life0, 'async_trait>( &'life0 mut self, frame: MediaFrame, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a frame to this sink.

fn flush<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Flush any internal buffers and signal end of stream.