Struct Reader 

pub struct Reader<T>
where
    T: CpuSample,
{ /* private fields */ }

Circuit Reader

Implementations

impl<T> Reader<T>

where T: CpuSample,

pub fn new() -> Self

Create circuit buffer reader

Trait Implementations

impl<T> BufferReader for Reader<T>

where T: CpuSample,

fn as_any_mut(&mut self) -> &mut dyn Any

for downcasting

fn init( &mut self, block_id: BlockId, port_id: PortId, inbox: Sender<BlockMessage>, )

Initialize buffer

fn validate(&self) -> Result<(), Error>

Check if connected

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

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

notify upstream that we are done

fn finish(&mut self)

The upstream is done

fn finished(&self) -> bool

Did the upstream already mark this buffer as done.

fn block_id(&self) -> BlockId

Own Block ID

fn port_id(&self) -> PortId

Own Port ID

impl<T> CpuBufferReader for Reader<T>

where T: CpuSample,

type Item = T

Buffer Items

fn slice_with_tags(&mut self) -> (&[Self::Item], &Vec<ItemTag>)

Get available samples and tags.

fn consume(&mut self, n: usize)

Consume Items

fn set_min_items(&mut self, _n: usize)

Configure the minimum numer of items required in work()

fn set_min_buffer_size_in_items(&mut self, _n: usize)

Configure the minimum buffer size

fn max_items(&self) -> usize

Maximum number of items that fit in the buffer

fn slice(&mut self) -> &[Self::Item]

Get available samples.

impl<T> Default for Reader<T>

where T: CpuSample,

fn default() -> Self

Returns the “default value” for a type.

impl<T> InplaceReader for Reader<T>

where T: CpuSample,

type Item = T

Items in the reader

type Buffer = Buffer<T>

Buffer type

fn get_full_buffer(&mut self) -> Option<Self::Buffer>

Get next buffer

fn has_more_buffers(&mut self) -> bool

Has more full buffers

fn put_empty_buffer(&mut self, buffer: Self::Buffer)

Put an empty buffer to circle it back to the beginning of the circuit

fn notify_consumed_buffer(&mut self)

Notify the circuit start that we consumed a buffer