Struct StreamProcessor 

pub struct StreamProcessor { /* private fields */ }

Stream processor for handling audio streams

Implementations

impl StreamProcessor

pub fn new(config: StreamConfig) -> Self

Create new stream processor

pub async fn with_converter_pool( config: StreamConfig, pool_size: usize, ) -> Result<Self>

Create stream processor with multiple converters

pub async fn add_converter(&self, converter: StreamingConverter)

Add a streaming converter to the pool

pub async fn process_stream( &self, audio_stream: AudioStream, ) -> Result<ProcessedAudioStream>

Process audio stream using load balancing

pub async fn process_multiple_streams( &self, streams: Vec<AudioStream>, ) -> Result<Vec<ProcessedAudioStream>>

Process multiple streams concurrently

pub async fn get_stats(&self) -> ProcessorStats

Get processor statistics

Trait Implementations

impl Debug for StreamProcessor

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

Formats the value using the given formatter.

impl Default for StreamProcessor

fn default() -> Self

Returns the “default value” for a type.