Struct ChannelStream 

pub struct ChannelStream { /* private fields */ }

Async channel-based stream adapter

Wraps a tokio channel receiver to provide async stream interface

Implementations

impl ChannelStream

pub fn new(config: StreamConfig, receiver: Receiver<Vec<f32>>) -> Self

Create a new channel stream

Trait Implementations

impl AsyncSignalStream for ChannelStream

fn read<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = IoResult<Array1<f32>>> + Send + 'async_trait>>

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

Read the next signal buffer asynchronously

fn is_active(&self) -> bool

Check if stream is still active

fn config(&self) -> &StreamConfig

Get stream configuration

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

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

Close the stream asynchronously