Struct FanInBuffer 

pub struct FanInBuffer<T: Transcendental, const N: usize, const PRODUCERS: usize> { /* private fields */ }

Buffer for mixing multiple producers to one consumer

Implementations

impl<T: Transcendental, const N: usize, const PRODUCERS: usize> FanInBuffer<T, N, PRODUCERS>

pub fn new() -> Self

Create new fan-in buffer

pub fn write(&self, producer_id: usize, data: &[T; N])

Write data from a specific producer

pub fn try_read(&self) -> Option<[T; N]>

Try to read mixed data from all producers

pub const fn producer_count(&self) -> usize

Get number of producers

pub fn producer_has_data(&self, producer_id: usize) -> bool

Check if producer has new data

pub fn read_seq(&self) -> usize

Get read sequence

pub fn write_seq(&self, producer_id: usize) -> Option<usize>

Get write sequence for producer

pub fn reset(&self)

Reset buffer

pub fn clear_producer(&self, producer_id: usize)

Clear specific producer

Trait Implementations

impl<T: Transcendental + Copy, const N: usize, const PRODUCERS: usize> Clone for FanInBuffer<T, N, PRODUCERS>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Transcendental + Debug, const N: usize, const PRODUCERS: usize> Debug for FanInBuffer<T, N, PRODUCERS>

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

Formats the value using the given formatter.

impl<T: Transcendental, const N: usize, const PRODUCERS: usize> Default for FanInBuffer<T, N, PRODUCERS>

fn default() -> Self

Returns the “default value” for a type.

impl<T: Transcendental, const N: usize, const PRODUCERS: usize> SignalBuffer<T> for FanInBuffer<T, N, PRODUCERS>

fn capacity(&self) -> usize

Get the total capacity of the buffer in samples

fn len(&self) -> usize

Get the current number of items in the buffer

fn is_empty(&self) -> bool

Check if the buffer is empty

fn is_full(&self) -> bool

Check if the buffer is full

fn clear(&mut self)

Clear all items from the buffer

fn stats(&self) -> BufferStats

Get a snapshot of current buffer statistics

fn reset_stats(&mut self)

Reset all statistics to zero