Struct RoomPacketSinkRegistry 

pub struct RoomPacketSinkRegistry {
    any_active: AtomicBool,
    generation: AtomicU64,
    active_rooms: RwLock<HashMap<RoomInstanceId, RegisteredPacketSink>>,
}

Fields

any_active: AtomicBool

generation: AtomicU64

active_rooms: RwLock<HashMap<RoomInstanceId, RegisteredPacketSink>>

Implementations

impl RoomPacketSinkRegistry

pub fn sink_for_room( &self, room_instance_id: RoomInstanceId, ) -> Option<RegisteredPacketSink>

fn generation(&self) -> u64

fn snapshot(&self) -> PacketSinkRegistrySnapshot

pub fn register_room( &self, room_instance_id: RoomInstanceId, sink: Arc<dyn PacketSink>, forward_destination_kind: RtpForwardDestinationKind, )

Registers sink for room_instance_id, replacing the current entry.

Previously cloned RegisteredPacketSink handles are not revoked.

pub fn unregister_room(&self, room_instance_id: RoomInstanceId)

Removes the current entry for room_instance_id.

Cached or cloned sink handles may still receive packets after unregister_room returns.

fn active_room_count(&self) -> usize

Trait Implementations

impl Debug for RoomPacketSinkRegistry

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

Formats the value using the given formatter.

impl Default for RoomPacketSinkRegistry

fn default() -> Self

Returns the “default value” for a type.