Searched refs:responder (Results 1 – 4 of 4) sorted by relevance
168 let responder = Arc::new(create_responder().await?); in main() localVariable171 responder.on_ice_candidate(Box::new(move |candidate: Option<RTCIceCandidate>| { in main()187 let maybe_responder = Arc::downgrade(&responder); in main()194 if let Some(responder) = maybe_responder.upgrade() { in main()195 if let Err(err) = responder.add_ice_candidate(candidate).await { in main()216 responder.on_peer_connection_state_change(Box::new(move |s: RTCPeerConnectionState| { in main()229 responder.set_remote_description(reqs).await?; in main()231 let resp = responder.create_answer(None).await?; in main()233 responder.set_local_description(resp.clone()).await?; in main()247 responder.close().await?; in main()
29 The demo code implements two endpoints (requester and responder) in it.38 | requester |----------------------->| responder |43 First requester and responder will exchange signaling message to establish a peer-to-peer47 1024-byte packets to responder, until you kill the process by Ctrl+С.
4 pub mod responder; module
9 use interceptor::nack::{generator::Generator, responder::Responder};57 let responder = Box::new(Responder::builder()); in configure_nack() localVariable58 registry.add(responder); in configure_nack()