Struct MediaStreamingService

pub struct MediaStreamingService { /* private fields */ }

Implementations

impl MediaStreamingService

pub fn new(buffer_capacity: usize) -> Self

pub async fn start_file_stream( &self, file_path: PathBuf, stream_config: MediaStream, ) -> RS2Stream<MediaChunk>

Start streaming from a file

pub async fn start_live_stream( &self, stream_config: MediaStream, ) -> RS2Stream<MediaChunk>

Start streaming from live input (camera, microphone, etc.)

pub fn determine_chunk_type(&self, sequence: u64) -> ChunkType

Determine chunk type based on sequence

pub fn determine_priority(&self, sequence: u64) -> MediaPriority

Determine priority based on sequence and chunk type

pub fn get_chunk_stream( &self, ) -> impl Stream<Item = MediaChunk> + Send + 'static

Get stream from priority queue

pub async fn get_metrics(&self) -> StreamMetrics

Get current metrics with updated buffer utilization

pub fn get_metrics_stream(&self) -> RS2Stream<StreamMetrics>

Create a metrics monitoring stream

pub async fn shutdown(&self)

Gracefully shutdown the streaming service