Struct CaptureManager 

pub(crate) struct CaptureManager {
    active: HashMap<u16, StreamCapture>,
}

Manages multiple concurrent voice-stream captures.

A single Tier 3 connection can multiplex voice streams across modules (e.g. a reflector with modules A, B, C each carrying an independent transmission at the same time). The CaptureManager maps each wire stream ID to its in-progress StreamCapture so that frames are routed correctly.

Lifecycle

1. Self::start — called on VoiceStart: registers a new capture keyed by the stream ID from the header.
2. Self::push_frame — called on VoiceFrame: appends the frame to the matching capture (no-op if the stream ID is unknown, which can happen if we missed the header).
3. Self::end — called on VoiceEnd: removes and returns the capture for finalization (MP3 encode + database insert).

Fields

active: HashMap<u16, StreamCapture>

Active captures keyed by the wire stream ID.

Implementations

impl CaptureManager

pub(crate) fn new() -> Self

Creates an empty manager with no active captures.

pub(crate) fn start(&mut self, capture: StreamCapture)

Registers a new capture. Replaces any existing entry for the same stream ID (a fresh header always supersedes any partial state).

pub(crate) fn push_frame(&mut self, stream_id: u16, frame: &VoiceFrame)

Appends a voice frame to the capture matching stream_id.

No-op (logs a debug message) if no capture is registered for this stream ID. This can happen if we joined the wire mid-stream and missed the header, or if a stale frame arrives after we already processed the VoiceEnd.

pub(crate) fn end(&mut self, stream_id: u16) -> Option<StreamCapture>

Finalizes and removes the capture matching stream_id.

Returns the captured state for downstream processing (MP3 encode, database insert). Returns None if no capture was registered for this stream ID.

pub(crate) fn active_count(&self) -> usize

Returns the number of captures currently in progress.

Used for observability (metrics exported on the HTTP API) and for backpressure decisions in the orchestrator.

Trait Implementations

impl Debug for CaptureManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for CaptureManager

fn default() -> CaptureManager

Returns the “default value” for a type.