Struct ChunkProducer 

pub struct ChunkProducer { /* private fields */ }

Handle for the processing thread. Pushes chunks using the DROP_OLDEST policy.

Implementations

impl ChunkProducer

pub fn push(&mut self, chunk: AudioChunk) -> Option<u64>

Push a chunk. If full, discard the oldest chunk (DROP_OLDEST) and count it.

Set dropped_before to the cumulative number of chunks discarded before this chunk was inserted, including the one evicted to make room for this chunk. Consumers can find the number dropped since the previous chunk from the difference between consecutive dropped_before values, and the total from the absolute value.

Return Some(total_dropped) if this push dropped a chunk (for deciding whether to fire crate::types::Event::ChunkDropped); otherwise return None.

pub fn dropped_count(&self) -> u64

Cumulative number of chunks discarded by DROP_OLDEST.