Struct RemoteSourceControl 

pub struct RemoteSourceControl {
    tx: Sender<RtcWorkerCommand>,
    target_id: RelayTargetId,
    rtc_metrics: Arc<RtcMetricsRecorder>,
}

command handle used by remote consumers to push control back to a source worker

a route that consumes media from another worker keeps this handle beside the remote-source registration later keyframe or layer-gate requests can then reach the worker that owns the producer without exposing the source worker internals

sends are deliberately best-effort stale remote routes, closed workers and full mailboxes are normal during teardown or topology churn

Fields

tx: Sender<RtcWorkerCommand>

target_id: RelayTargetId

rtc_metrics: Arc<RtcMetricsRecorder>

Implementations

impl RemoteSourceControl

pub(super) fn new( tx: Sender<RtcWorkerCommand>, target_id: RelayTargetId, rtc_metrics: Arc<RtcMetricsRecorder>, ) -> Self

creates a source-control handle for one relay target on a worker mailbox

pub(super) fn request_kf( &self, source: &TransportSourceKey, rid: Option<Rid>, kind: KeyframeRequestKind, ) -> RemoteControlSendOutcome

asks the source worker to request a keyframe for a remote consumer

this never waits for the source worker Full retains caller-side retry authority while Closed ends it

pub(super) fn set_pkt_gate( &self, source: &TransportSourceKey, packet_gate: PacketLayerGate, ) -> bool

publishes the effective remote-source packet gate to the source worker

pub(super) fn record_pkt_gate_retry(&self)

pub(super) fn record_pkt_gate_flushed(&self)

fn send_command( &self, request: RouteControlRequest, drop_kind: RtcRemoteControlDropKind, ) -> RemoteControlSendOutcome

Trait Implementations

impl Clone for RemoteSourceControl

fn clone(&self) -> RemoteSourceControl

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RemoteSourceControl

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

Formats the value using the given formatter.