Struct Producer 

pub struct Producer { /* private fields */ }

The producer half of the ring buffer. Not Clone — enforces single-producer.

Implementations

impl Producer

pub fn push(&self, sample: f32)

Push a sample into the buffer. If the buffer is full, the oldest sample is overwritten.

Examples

let (p, c) = rt_ring::new(4);
p.push(0.5);
assert_eq!(c.pop(), Some(0.5));

pub fn push_slice(&self, samples: &[f32])

Push a slice of samples into the buffer. Samples that cause overflow overwrite the oldest data.

Examples

let (p, c) = rt_ring::new(4);
p.push_slice(&[1.0, 2.0, 3.0]);
let mut buf = [0.0f32; 3];
let n = c.pop_slice(&mut buf);
assert_eq!(n, 3);
assert_eq!(&buf, &[1.0, 2.0, 3.0]);

pub fn available(&self) -> usize

Returns the number of samples currently available for reading.

Examples

let (p, c) = rt_ring::new(4);
assert_eq!(p.available(), 0);
p.push(1.0);
p.push(2.0);
assert_eq!(p.available(), 2);
c.pop();
assert_eq!(p.available(), 1);

pub fn capacity(&self) -> usize

Returns the buffer capacity (always a power of two).

Examples

let (p, _c) = rt_ring::new(5);
assert_eq!(p.capacity(), 8); // rounded up to next power of two

pub fn overwrite_count(&self) -> u64

Returns the total number of samples that were overwritten since creation.

Equivalent to Consumer::overwrite_count — both read the same atomic counter.

Examples

let (p, c) = rt_ring::new(4);
for i in 0..10 {
    p.push(i as f32);
}
assert_eq!(p.overwrite_count(), 6);
assert_eq!(p.overwrite_count(), c.overwrite_count());