Struct SharedAsyncStream 

pub struct SharedAsyncStream { /* private fields */ }

A shared async stream for multiple producers

Implementations

impl SharedAsyncStream

pub async fn new( context: &WhisperContext, params: FullParams, config: WhisperStreamConfig, ) -> Result<Self>

Create a new shared async stream

pub async fn feed_and_process(&self, audio: Vec<f32>) -> Result<Vec<Segment>>

Feed audio and get segments atomically

pub async fn drain_segments(&self) -> Vec<Segment>

Drain all pending segments

pub async fn flush(&self) -> Result<Vec<Segment>>

Flush the stream

Trait Implementations

impl Clone for SharedAsyncStream

Available on crate feature async only.

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.