Struct GapClient 

pub struct GapClient { /* private fields */ }

Stateful GAP client.

Maintains an outbound rtp_sequence counter and an inbound replay window, both keyed by media_source_id.

The client observes the current group epoch on every GapClient::send or GapClient::accept call and automatically clears its replay window when the epoch advances. Callers may also drive a reset explicitly via GapClient::reset.

Old-epoch windows are retained for timeouts::T_GAP_KEY_OVERLAP_MS (default 10 s) so that in-flight audio frames from the previous epoch can still be accepted after an epoch transition (gap_rfc §4).

Implementations

impl GapClient

pub fn new() -> Self

Creates an empty client.

pub fn send<S: Sealer>( &mut self, node: &mut GroupNode, seal: &mut S, target: MemberId, media_source_id: u32, rtp_timestamp: u64, opus: Vec<u8>, codec: PayloadCodec, ) -> Result<OutboundFrame, GapError>

Sends an Opus frame. key_phase is taken from node.current_epoch. Uses the O profile (no R / A — voice is not reliable, GAP §7).

The wire rtp_sequence is clamped to the 16-bit RTP range; on overflow it wraps from 0xFFFF back to 0x0000. codec controls how the payload is encoded; use PayloadCodec::Cbor for maximum compatibility or PayloadCodec::FlatBuffers for lowest decode latency.

pub fn accept( &mut self, plaintext: &[u8], current_epoch: u64, codec: PayloadCodec, ) -> Result<GapAccept, GapError>

Accepts a plaintext payload delivered by the GBP layer.

Returns GapAccept::New for fresh frames, GapAccept::Late for replays that the spec allows to drop. Returns GapError::EpochStale only when key_phase refers to an epoch that has already expired its T_overlap window; frames from epochs still within T_overlap are accepted normally (gap_rfc §4). codec must match [DeliveredPayload::codec].

pub fn sync_epoch(&mut self, epoch: u64)

Synchronises the client’s view of the group epoch.

When the epoch advances, the current replay window is moved to the overlap buffer (retained for T_GAP_KEY_OVERLAP_MS) instead of being discarded, so late in-flight frames from the previous epoch are still accepted (gap_rfc §4). Expired entries are pruned on each call. Called automatically by GapClient::send and GapClient::accept.

pub fn reset(&mut self)

Clears the outbound counters, the replay window, and the overlap buffer unconditionally.

Trait Implementations

impl Default for GapClient

fn default() -> Self

Returns the “default value” for a type.