Struct WebRtcConnection 

pub struct WebRtcConnection { /* private fields */ }

WebRtcConnection - WebRTC P2P Connect

Implementations

impl WebRtcConnection

pub fn new( peer_id: ActrId, peer_connection: Arc<RTCPeerConnection>, event_tx: Sender<ConnectionEvent>, ) -> Self

Create WebRtcConnection from RTCPeerConnection

Arguments

• peer_id: Peer identity for event identification
• peer_connection: Arc wrapped RTCPeerConnection
• event_tx: Broadcast sender for connection events

pub fn peer_id(&self) -> &ActrId

Get peer ID

pub fn install_state_change_handler(&self)

Install a state-change handler on the underlying RTCPeerConnection.

This keeps connected in sync with the WebRTC connection state and proactively closes the PeerConnection and clears internal caches when entering a terminal state (Disconnected/Failed/Closed).

pub async fn connect(&self) -> NetworkResult<()>

establish Connect（WebRTC Connect already alreadyvia signaling establish ， this in only is mark record ）

pub fn subscribe_events(&self) -> Receiver<ConnectionEvent>

Subscribe to connection events

pub fn is_connected(&self) -> bool

Checkwhether already Connect

pub async fn close(&self) -> NetworkResult<()>

Close connection and broadcast ConnectionClosed event

impl WebRtcConnection

pub async fn get_lane( &self, payload_type: PayloadType, ) -> NetworkResult<DataLane>

GetorCreate DataLane（ carry Cache）

pub async fn invalidate_lane(&self, payload_type: PayloadType)

Invalidate cached lane/DataChannel for given payload type.

Used when the underlying DataChannel has transitioned to Closed and needs to be recreated on next get_lane call.

pub async fn add_media_track( &self, track_id: String, codec: &str, media_type: &str, ) -> NetworkResult<Arc<TrackLocalStaticRTP>>

Add media track to PeerConnection

Arguments

• track_id: Unique track identifier
• codec: Codec name (e.g., “H264”, “VP8”, “opus”)
• media_type: “video” or “audio”

Returns

Reference to the created TrackLocalStaticRTP

Note

Must be called BEFORE create_offer/create_answer for track to appear in SDP

pub async fn get_media_track( &self, track_id: &str, ) -> Option<Arc<TrackLocalStaticRTP>>

Get existing media track by ID

pub async fn next_sequence_number(&self, track_id: &str) -> Option<u16>

Get next RTP sequence number for track (atomically increments)

Arguments

• track_id: Track identifier

Returns

Next sequence number (wraps at 65535)

pub async fn get_ssrc(&self, track_id: &str) -> Option<u32>

Get SSRC for track

Arguments

• track_id: Track identifier

Returns

SSRC value for this track

pub async fn create_lane( &self, payload_type: PayloadType, ) -> NetworkResult<DataLane>

GetorCreate MediaTrack Lane（ carry Cache）

Arguments

• _stream_id: Media stream ID

backwardaftercompatible hold Method：create_lane adjust usage get_lane

pub async fn register_received_data_channel( &self, data_channel: Arc<RTCDataChannel>, payload_type: PayloadType, message_tx: UnboundedSender<(Vec<u8>, Bytes, PayloadType)>, ) -> NetworkResult<DataLane>

Register received DataChannel (for passive side)

When receiving an Offer, the passive side should register DataChannels received via on_data_channel callback instead of creating new ones.

Trait Implementations

impl Clone for WebRtcConnection

fn clone(&self) -> WebRtcConnection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WebRtcConnection

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

Formats the value using the given formatter.