Struct AsyncMemoryStream 

pub struct AsyncMemoryStream { /* private fields */ }

Async in-memory signal stream for testing

Implementations

impl AsyncMemoryStream

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

Create a new async memory stream from data

pub fn from_array(data: Array1<f32>, config: StreamConfig) -> Self

Create from an array

Trait Implementations

impl AsyncSignalStream for AsyncMemoryStream

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

impl Debug for AsyncMemoryStream

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

Formats the value using the given formatter.