Struct ChunkProducer 

pub struct ChunkProducer { /* private fields */ }

加工スレッド側のハンドル。DROP_OLDEST 方針で push する。

Implementations

impl ChunkProducer

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

チャンクを push する。満杯なら最古を捨て（DROP_OLDEST）、捨てた数を数える。

dropped_before には、このチャンクが入るまでに累計で捨てたチャンク数 （このチャンクのための追い出し 1 件を含む）を入れる。消費側は連続チャンクの dropped_before の差分で直前の欠落数を、絶対値で累計欠落数を知れる。

この push でドロップが起きたら Some(累計ドロップ数) を返す （crate::types::Event::ChunkDropped の発火判断に使える）。起きなければ None。

pub fn dropped_count(&self) -> u64

これまでに DROP_OLDEST で捨てた累計チャンク数。