Struct FanInBuffer 

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

Buffer for mixing multiple producers to one consumer. Single-threaded — use rill_core::queues for cross-thread.

Implementations

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

pub fn new() -> Self

Create a new fan-in buffer.

Panics

Panics if PRODUCERS is 0.

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

Write a block of data from one producer.

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

Read and sum all producers’ data that have new writes since last read.

pub const fn producer_count(&self) -> usize

Number of producers (const generic parameter).

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

Whether a specific producer has unread data.

pub fn read_seq(&self) -> usize

Current read sequence counter.

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

Write sequence counter for a specific producer, or None if ID is invalid.

pub fn reset(&mut self)

Reset all producers and the read counter.

pub fn clear_producer(&mut self, producer_id: usize)

Clear a specific producer’s data without affecting others.

Trait Implementations

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

fn capacity(&self) -> usize

Maximum number of elements the buffer can hold.

fn len(&self) -> usize

Current number of elements in the buffer.

fn is_empty(&self) -> bool

Whether the buffer is empty (len() == 0).

fn is_full(&self) -> bool

Whether the buffer is full (len() == capacity()).

fn as_slice(&self) -> &[T]

Read-only access to the buffer data.

fn as_mut_slice(&mut self) -> &mut [T]

Mutable access to the buffer data.

fn fill(&mut self, value: T)

Fill the entire buffer with a value.

fn copy_from(&mut self, src: &[T])

Copy data from a slice. Copies min(src.len(), self.len()) samples.

fn clear(&mut self)

Remove all items from the buffer.

fn stats(&self) -> BufferStats

Snapshot of performance statistics.

fn reset_stats(&mut self)

Reset performance counters (not the data).

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.