Struct FanOutBuffer 

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

Buffer for broadcasting from one producer to multiple consumers. Single-threaded — use rill_core::queues for cross-thread.

Implementations

impl<T: Transcendental, const N: usize, const CONSUMERS: usize> FanOutBuffer<T, N, CONSUMERS>

pub fn new() -> Self

Create a new fan-out buffer.

Panics

Panics if CONSUMERS is 0.

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

Broadcast data to all consumers.

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

Read data for a specific consumer, returning None if already read or no data available.

pub fn has_new_data(&self, consumer_id: usize) -> bool

Whether unread data exists for the given consumer.

pub const fn consumer_count(&self) -> usize

Number of consumers (const generic parameter).

pub fn current_version(&self) -> usize

Current write version.

pub fn last_read_version(&self, consumer_id: usize) -> Option<usize>

Version last read by a consumer, or None if consumer ID is invalid.

pub fn reset(&mut self)

Reset to initial state (invalid, all consumers at version 0).

Trait Implementations

impl<T: Transcendental + Debug, const N: usize, const CONSUMERS: usize> Debug for FanOutBuffer<T, N, CONSUMERS>

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

Formats the value using the given formatter.

impl<T: Transcendental, const N: usize, const CONSUMERS: usize> Default for FanOutBuffer<T, N, CONSUMERS>

fn default() -> Self

Returns the “default value” for a type.

impl<T: Transcendental, const N: usize, const CONSUMERS: usize> SignalBuffer<T> for FanOutBuffer<T, N, CONSUMERS>

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