Struct StreamingPanako 

pub struct StreamingPanako { /* private fields */ }

Streaming Panako fingerprinter.

Same deferred-emission strategy as super::StreamingWang: hashes are emitted only once their anchor has accrued the full lookahead, so the output multiset matches Panako::extract for the same total input.

Latency is higher than Wang because the triplet zone is wider (target_zone_t = 96 vs Wang’s 63).

The pipeline is shared with StreamingWang via the crate-internal streaming core; this wrapper supplies only the Panako-specific triplet emission.

Implementations

impl StreamingPanako

pub fn new(cfg: PanakoConfig) -> Self

Build a streaming Panako extractor with the given config.

Clamps target_zone_t to a minimum of 1 and fan_out to a minimum of 1 to prevent underflows/empty output from degenerate configurations. Caps target_zone_t at 512 and fan_out at 64 to prevent OOM from extreme values.

pub fn config(&self) -> &PanakoConfig

Borrow the configuration this stream was built with.

pub fn reset(&mut self)

Reset all internal state. The stream behaves as if freshly constructed: no buffered audio, no pending peaks or anchors. Call between independent streams sharing one instance so stale data from a previous stream doesn’t bleed into new hashes.

pub fn flush_complete(&mut self) -> Result<Vec<(TimestampMs, PanakoHash)>>

Corrected end-of-stream finalisation matching offline Panako::extract.

See StreamingWang::flush_complete for the legacy-vs-corrected flush contract and when to opt in.

pub fn flush_complete_with<F>(&mut self, callback: F) -> Result<usize>

where F: FnMut(TimestampMs, &PanakoHash),

Callback variant of flush_complete.

Trait Implementations

impl Default for StreamingPanako

fn default() -> Self

Returns the “default value” for a type.

impl StreamingFingerprinter for StreamingPanako

type Frame = PanakoHash

One unit of fingerprint material the stream emits.

fn required_sample_rate(&self) -> u32

Sample rate, in hertz, the stream expects its input at.

fn push(&mut self, samples: &[f32]) -> Result<Vec<(TimestampMs, Self::Frame)>>

Feed PCM samples and return any fingerprints that became available during this push.

fn push_with<F>(&mut self, samples: &[f32], callback: F) -> Result<usize>

where F: FnMut(TimestampMs, &Self::Frame),

Feed PCM samples and invoke callback for each fingerprint frame that became available during this push.

fn flush(&mut self) -> Result<Vec<(TimestampMs, Self::Frame)>>

Drain any pending fingerprint material at end-of-stream.

fn flush_with<F>(&mut self, callback: F) -> Result<usize>

where F: FnMut(TimestampMs, &Self::Frame),

Drain any pending fingerprint material at end-of-stream, invoking callback for each frame.

fn latency_ms(&self) -> u32

Conservative upper bound on emission latency: from the time a sample enters push to the time the fingerprint covering it is returned.

fn push_strict( &mut self, samples: &[f32], ) -> Result<Vec<(TimestampMs, Self::Frame)>>

Like push, but fail fast on non-finite input instead of sanitizing it to 0.0.

impl ZeroAllocStreaming for StreamingPanako