Struct WebRtcProtocolHandler 

pub struct WebRtcProtocolHandler { /* private fields */ }

WebRTC protocol handler for SharedTransport.

Routes incoming streams to the appropriate WebRTC subsystem based on stream type:

• WebRtcSignal (0x20): SDP offers/answers, ICE candidates
• WebRtcMedia (0x21): RTP packets for audio/video
• WebRtcData (0x22): Data channel messages

Implementations

impl WebRtcProtocolHandler

pub fn new( config: WebRtcHandlerConfig, ) -> (Self, Receiver<WebRtcIncoming>, Receiver<WebRtcIncoming>, Receiver<WebRtcIncoming>)

Create a new WebRTC protocol handler.

Returns the handler and receivers for each message type.

pub fn with_defaults() -> (Self, Receiver<WebRtcIncoming>, Receiver<WebRtcIncoming>, Receiver<WebRtcIncoming>)

Create with default configuration.

pub async fn session_count(&self) -> usize

Get number of active sessions.

pub async fn get_session_stats(&self, peer: &PeerId) -> Option<(u64, Vec<u32>)>

Get session info for a peer.

pub async fn remove_session(&self, peer: &PeerId)

Remove a peer session.

impl WebRtcProtocolHandler

pub fn route_packet_to_stream(payload: &[u8]) -> StreamType

Route an incoming packet to the correct stream type

Arguments

• payload - The packet payload

Returns

The target StreamType for this packet

pub fn stream_media_type(stream_type: StreamType) -> &'static str

Get the media type for a stream

Arguments

• stream_type - The stream type

Returns

A description of the media type

Trait Implementations

impl ProtocolHandler for WebRtcProtocolHandler

fn stream_types(&self) -> &[StreamType]

Get the stream types this handler processes.

fn handle_stream<'life0, 'async_trait>( &'life0 self, peer: PeerId, stream_type: StreamType, data: Bytes, ) -> Pin<Box<dyn Future<Output = TransportResult<Option<Bytes>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle an incoming stream.

fn handle_datagram<'life0, 'async_trait>( &'life0 self, peer: PeerId, stream_type: StreamType, data: Bytes, ) -> Pin<Box<dyn Future<Output = TransportResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle an incoming datagram.

fn shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = TransportResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called when the handler is being shut down.

fn name(&self) -> &str

Get a human-readable name for this handler.