Home
last modified time | relevance | path

Searched refs:peer_connection (Results 1 – 3 of 3) sorted by relevance

/xiu/protocol/webrtc/src/
H A Dwhip.rs14 use webrtc::peer_connection::configuration::RTCConfiguration;
17 use webrtc::peer_connection::RTCPeerConnection;
63 peer_connection in handle_whip()
72 peer_connection in handle_whip()
85 let pc = Arc::downgrade(&peer_connection); in handle_whip()
86 peer_connection.on_track(Box::new(move |track, _, _| { in handle_whip()
156 peer_connection.on_ice_connection_state_change(Box::new( in handle_whip()
183 peer_connection.set_remote_description(offer).await?; in handle_whip()
186 let answer = peer_connection.create_answer(None).await?; in handle_whip()
192 peer_connection.set_local_description(answer).await?; in handle_whip()
[all …]
H A Dwhep.rs14 use webrtc::peer_connection::configuration::RTCConfiguration;
16 use webrtc::peer_connection::sdp::session_description::RTCSessionDescription;
17 use webrtc::peer_connection::RTCPeerConnection;
26 use webrtc::peer_connection::peer_connection_state::RTCPeerConnectionState;
88 let rtp_sender = peer_connection in handle_whep()
92 let _ = peer_connection in handle_whep()
107 peer_connection.on_ice_connection_state_change(Box::new( in handle_whep()
138 peer_connection.set_remote_description(offer).await?; in handle_whep()
141 let answer = peer_connection.create_answer(None).await?; in handle_whep()
147 peer_connection.set_local_description(answer).await?; in handle_whep()
[all …]
/xiu/protocol/webrtc/src/session/
H A Dmod.rs35 use webrtc::peer_connection::peer_connection_state::RTCPeerConnectionState;
36 use webrtc::peer_connection::{sdp::session_description::RTCSessionDescription, RTCPeerConnection};
48 pub peer_connection: Option<Arc<RTCPeerConnection>>, field
64 peer_connection: None, in new()
69 if let Some(pc) = &self.peer_connection { in close_peer_connection()
274 Ok((session_description, peer_connection)) => { in publish_whip()
275 self.peer_connection = Some(peer_connection); in publish_whip()
352 Ok((session_description, peer_connection)) => { in subscribe_whep()
353 let pc_clone = peer_connection.clone(); in subscribe_whep()
390 self.peer_connection = Some(peer_connection); in subscribe_whep()