Struct StreamingHaitsma 

pub struct StreamingHaitsma { /* private fields */ }

Streaming Haitsma–Kalker fingerprinter.

Trivially incremental: each output bit-frame depends only on the current and previous frames’ band energies, so we just keep one previous-frame energy vector. No spectrogram window, no peak picker, no per-second adaptive threshold. Per-push CPU cost is proportional to the number of new samples, independent of total stream length, and latency is bounded by the STFT window length (n_fft / sr ≈ 410 ms) — much lower than the landmark extractors.

Output is bit-exactly equivalent to Haitsma::extract.

Implementations

impl StreamingHaitsma

pub fn new(cfg: HaitsmaConfig) -> Self

Build a streaming Haitsma extractor with the given config.

Panics

Panics if cfg.fmin <= 0, cfg.fmax <= cfg.fmin, or cfg.fmax >= HAITSMA_SR / 2 (above Nyquist). Use try_new for a fallible alternative.

pub fn try_new(cfg: HaitsmaConfig) -> Result<Self>

Fallible constructor — returns AfpError::Config on invalid fmin/fmax/Nyquist instead of panicking.

pub fn config(&self) -> &HaitsmaConfig

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 frames, frame counter restarted. Call between independent input streams sharing one instance.

Trait Implementations

impl Default for StreamingHaitsma

fn default() -> Self

Returns the “default value” for a type.

impl StreamingFingerprinter for StreamingHaitsma

type Frame = u32

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 StreamingHaitsma