Struct PipeBuffer 

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

Single-producer, single-consumer buffer for intra-graph node connections.

Unlike its name suggests, this is not thread-safe — it is used exclusively within the single-threaded signal graph. For cross-thread communication use rill_core::queues.

Implementations

impl<T, const N: usize> PipeBuffer<T, N>

where T: Transcendental,

pub fn new() -> PipeBuffer<T, N>

Create a new empty pipe buffer.

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

Write a block of data. Subsequent reads will return this data.

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

Read the latest written data (non-destructive).

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

Read the latest written data (destructive — clears the valid flag).

pub fn read_blocking(&mut self) -> [T; N]

Busy-wait until data is available, then read destructively.

pub fn has_data(&self) -> bool

Whether data is available for reading.

pub fn write_seq(&self) -> usize

Number of writes performed.

pub fn read_seq(&self) -> usize

Number of reads performed.

pub fn is_caught_up(&self) -> bool

Whether all writes have been consumed by reads.

pub fn overwrites(&self) -> usize

Number of times the buffer was overwritten before being read.

pub fn reset(&mut self)

Reset to initial empty state.

Trait Implementations

impl<T, const N: usize> Buffer<T> for PipeBuffer<T, N>

where T: Transcendental,

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, const N: usize> Clone for PipeBuffer<T, N>

where T: Transcendental + Copy,

fn clone(&self) -> PipeBuffer<T, N>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T, const N: usize> Debug for PipeBuffer<T, N>

where T: Transcendental + Debug,

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

Formats the value using the given formatter.

impl<T, const N: usize> Default for PipeBuffer<T, N>

where T: Transcendental,

fn default() -> PipeBuffer<T, N>

Returns the “default value” for a type.