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.

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>, ) -> 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.

pub fn accept( &mut self, plaintext: &[u8], current_epoch: u64, ) -> 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, or GapError::EpochStale when key_phase does not match the current epoch.

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

Synchronises the client’s view of the group epoch and resets the outbound counters and replay window when the epoch has advanced. Called automatically by GapClient::send and GapClient::accept.

pub fn reset(&mut self)

Clears the outbound counters and the replay window unconditionally.

Trait Implementations

impl Default for GapClient

fn default() -> GapClient

Returns the “default value” for a type.