Struct UserOutboundSender 

pub struct UserOutboundSender {
    messages: Sender<QueuedUserOutbound>,
    overflow: Sender<Option<UserOutboundOverflow>>,
    metrics: Arc<RuntimeMetrics>,
    limits: UserOutboundQueueLimits,
    queued_bytes: Arc<AtomicUsize>,
    latest_track_snapshot: Arc<Mutex<Option<VersionedRemoteTrackSnapshot>>>,
}

Fields

messages: Sender<QueuedUserOutbound>

overflow: Sender<Option<UserOutboundOverflow>>

metrics: Arc<RuntimeMetrics>

limits: UserOutboundQueueLimits

queued_bytes: Arc<AtomicUsize>

latest_track_snapshot: Arc<Mutex<Option<VersionedRemoteTrackSnapshot>>>

Implementations

impl UserOutboundSender

pub fn channel( capacity: usize, metrics: Arc<RuntimeMetrics>, ) -> (Self, UserOutboundReceiver)

pub fn channel_with_limits( limits: UserOutboundQueueLimits, metrics: Arc<RuntimeMetrics>, ) -> (Self, UserOutboundReceiver)

pub fn send(&self, outbound: UserOutbound) -> Result<(), UserOutboundSendError>

Enqueues outbound without waiting for capacity.

UserOutboundSendError::Full also signals an overflow event for UserOutboundReceiver::recv_event.

Errors

Returns UserOutboundSendError::Full when message-count or byte capacity is exhausted. Returns UserOutboundSendError::Closed when the receiver has been dropped.

pub(super) fn send_remote_tracks( &self, snapshot: VersionedRemoteTrackSnapshot, ) -> Result<(), UserOutboundSendError>

Suppresses older track state while carrying every late negotiation edge forward on the latest snapshot.

fn enqueue(&self, outbound: UserOutbound) -> Result<(), UserOutboundSendError>

fn reserve_bytes(&self, bytes: usize) -> Result<(), UserOutboundSendError>

fn release_bytes(&self, bytes: usize)

fn mark_overflow( &self, kind: UserOutboundOverflowKind, queued_bytes: usize, message_bytes: usize, ) -> UserOutboundOverflow

Trait Implementations

impl Clone for UserOutboundSender

fn clone(&self) -> UserOutboundSender

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UserOutboundSender

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

Formats the value using the given formatter.