Struct RingBuffer 

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

Кольцевой буфер с фиксированным размером

Пример

use rill_core::buffer::RingBuffer;

let mut buffer = RingBuffer::<f32, 4>::new();
buffer.write(1.0);
buffer.write(2.0);
buffer.write(3.0);
buffer.write(4.0);

assert_eq!(buffer.read_delayed(0), 4.0); // последний записанный
assert_eq!(buffer.read_delayed(1), 3.0);
assert_eq!(buffer.read_delayed(2), 2.0);
assert_eq!(buffer.read_delayed(3), 1.0);

Implementations

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

where T: Transcendental,

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

Создать новый кольцевой буфер

Panics

Паникует, если N не является степенью двойки

pub fn write(&mut self, sample: T)

Записать семпл (всегда успешно, перезаписывает старые данные)

Safety

Эта операция безопасна, потому что:

1. head уникален для производителя
2. Производитель никогда не читает из своей позиции
3. Атомарные операции гарантируют видимость

pub fn write_slice(&mut self, samples: &[T])

Записать массив семплов

pub fn read(&mut self) -> Option<T>

Прочитать семпл (если есть)

Returns

• Some(sample) - семпл успешно прочитан
• None - буфер пуст

pub fn read_delayed(&self, delay: usize) -> T

Прочитать семпл с задержкой (без изменения указателей)

Arguments

• delay - задержка в семплах (0 = последний записанный)

Panics

Паникует, если delay >= len()

pub fn read_interpolated(&self, delay_frac: f32) -> T

where T: From<f32> + Into<f32>,

Прочитать с интерполяцией (для дробных задержек)

Arguments

• delay_frac - задержка в семплах с дробной частью

Returns

Интерполированное значение (линейная интерполяция)

pub fn read_sequence_interpolated(&self, start_delay: f32, output: &mut [T])

where T: From<f32> + Into<f32>,

Прочитать последовательность с интерполяцией

Arguments

• start_delay - начальная задержка
• output - буфер для записи результата

pub fn len(&self) -> usize

Текущий размер (количество элементов в буфере)

pub const fn capacity(&self) -> usize

Вместимость буфера

pub fn is_empty(&self) -> bool

Проверить, пуст ли буфер

pub fn is_full(&self) -> bool

Проверить, полон ли буфер

pub fn clear(&mut self)

Очистить буфер (сбросить указатели)

pub fn reset(&mut self)

Сбросить буфер без обнуления данных (быстрее)

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

where T: Transcendental,

pub fn iter(&self) -> RingBufferIter<'_, T, N>

Получить итератор по элементам буфера (от самого старого к самому новому)

Trait Implementations

impl<T, const N: usize> Debug for RingBuffer<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 RingBuffer<T, N>

where T: Transcendental,

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

Returns the “default value” for a type.

impl<T, const N: usize> Send for RingBuffer<T, N>

where T: Transcendental + Send,

impl<T, const N: usize> Sync for RingBuffer<T, N>

where T: Transcendental + Sync,