Home
last modified time | relevance | path

Searched refs:Receiver (Results 1 – 25 of 40) sorted by relevance

12

/webrtc/interceptor/src/twcc/receiver/
H A Dmod.rs35 Ok(Arc::new(Receiver { in build()
65 packet_chan_rx: Mutex<Option<mpsc::Receiver<Packet>>>,
67 close_rx: Mutex<Option<mpsc::Receiver<()>>>,
72 pub struct Receiver { struct
83 impl Receiver { argument
150 impl Interceptor for Receiver { implementation
183 if let Err(err) = Receiver::run(writer2, internal).await { in bind_rtcp_writer()
H A Dreceiver_test.rs15 let builder = Receiver::builder(); in test_twcc_receiver_interceptor_before_any_packets()
48 let builder = Receiver::builder(); in test_twcc_receiver_interceptor_after_rtp_packets()
104 let builder = Receiver::builder().with_interval(Duration::from_millis(500)); in test_twcc_receiver_interceptor_different_delays_between_rtp_packets()
176 let builder = Receiver::builder().with_interval(Duration::from_secs(2)); in test_twcc_receiver_interceptor_packet_loss()
283 let builder = Receiver::builder(); in test_twcc_receiver_interceptor_overflow()
/webrtc/webrtc/src/api/interceptor_registry/
H A Dmod.rs12 use interceptor::twcc::{receiver::Receiver, sender::Sender};
97 let receiver = Box::new(Receiver::builder()); in configure_twcc()
165 let receiver = Box::new(Receiver::builder()); in configure_twcc_receiver_only()
/webrtc/interceptor/src/mock/
H A Dmock_stream.rs21 rtcp_in_rx: Mutex<mpsc::Receiver<RTCPPackets>>,
22 rtp_in_rx: Mutex<mpsc::Receiver<rtp::packet::Packet>>,
24 rtcp_out_modified_rx: Mutex<mpsc::Receiver<RTCPPackets>>,
25 rtp_out_modified_rx: Mutex<mpsc::Receiver<rtp::packet::Packet>>,
29 rtcp_in_modified_rx: Mutex<mpsc::Receiver<Result<RTCPPackets>>>,
30 rtp_in_modified_rx: Mutex<mpsc::Receiver<Result<rtp::packet::Packet>>>,
/webrtc/turn/src/server/
H A Dmod.rs150 mut handle_rx: broadcast::Receiver<Command>, in read_loop()
248 DeleteAllocations(String, Arc<mpsc::Receiver<()>>),
259 Close(Arc<mpsc::Receiver<()>>),
/webrtc/sctp/src/association/
H A Dmod.rs206 close_loop_ch_rx: Mutex<broadcast::Receiver<()>>,
207 accept_ch_rx: Mutex<mpsc::Receiver<Arc<Stream>>>,
285 async fn new(config: Config, is_client: bool) -> Result<(Self, mpsc::Receiver<Option<Error>>)> { in new()
427 mut close_loop_ch: broadcast::Receiver<()>, in read_loop() argument
482 mut close_loop_ch: broadcast::Receiver<()>, in write_loop() argument
484 mut awake_write_loop_ch: mpsc::Receiver<()>, in write_loop() argument
/webrtc/util/src/conn/
H A Dconn_udp_listener.rs19 type AcceptDoneCh = (mpsc::Receiver<Arc<UdpConn>>, watch::Receiver<()>);
141 mut done_ch_rx: watch::Receiver<()>, in read_loop() argument
H A Dconn_pipe.rs8 rd_rx: Mutex<mpsc::Receiver<Vec<u8>>>,
/webrtc/ice/src/agent/
H A Dagent_internal.rs24 pub(crate) on_connected_rx: Mutex<Option<mpsc::Receiver<()>>>,
31 Mutex<Option<(mpsc::Receiver<()>, mpsc::Receiver<bool>)>>,
1028 initialized_ch: Option<broadcast::Receiver<()>>, in start_candidate() argument
1054 mut chan_state_rx: mpsc::Receiver<ConnectionState>, in start_on_connection_state_change_routine()
1055 mut chan_candidate_rx: mpsc::Receiver<Option<Arc<dyn Candidate + Send + Sync>>>, in start_on_connection_state_change_routine()
1056 mut chan_candidate_pair_rx: mpsc::Receiver<()>, in start_on_connection_state_change_routine() argument
1117 mut closed_ch_rx: broadcast::Receiver<()>, in recv_loop() argument
1118 initialized_ch: Option<broadcast::Receiver<()>>, in recv_loop() argument
H A Dagent_transport.rs18 mut cancel_rx: mpsc::Receiver<()>, in dial() argument
53 mut cancel_rx: mpsc::Receiver<()>, in accept() argument
H A Dmod.rs89 chan_state_rx: mpsc::Receiver<ConnectionState>,
90 chan_candidate_rx: mpsc::Receiver<Option<Arc<dyn Candidate + Send + Sync>>>,
91 chan_candidate_pair_rx: mpsc::Receiver<()>,
/webrtc/turn/src/client/
H A Dtransaction.rs123 result_ch_rx: Option<mpsc::Receiver<TransactionResult>>,
216 pub fn get_result_channel(&mut self) -> Option<mpsc::Receiver<TransactionResult>> { in get_result_channel()
/webrtc/ice/src/udp_mux/
H A Dudp_mux_conn.rs41 closed_watch_rx: watch::Receiver<bool>,
105 pub fn close_rx(&self) -> watch::Receiver<bool> { in close_rx()
H A Dmod.rs81 closed_watch_rx: watch::Receiver<()>,
163 fn start_conn_worker(self: Arc<Self>, mut closed_watch_rx: watch::Receiver<()>) { in start_conn_worker() argument
/webrtc/examples/examples/signal/src/
H A Dlib.rs53 pub async fn http_sdp_server(port: u16) -> mpsc::Receiver<String> { in http_sdp_server()
/webrtc/webrtc/src/peer_connection/operation/
H A Dmod.rs112 mut close_rx: mpsc::Receiver<()>, in start() argument
/webrtc/mdns/src/conn/
H A Dmod.rs166 mut close_query_signal: mpsc::Receiver<()>, in query() argument
244 mut closed_rx: mpsc::Receiver<()>, in start() argument
/webrtc/webrtc/src/peer_connection/
H A Dpeer_connection_test.rs173 mut done_rx: mpsc::Receiver<()>, in close_pair() argument
205 mut done_rx: mpsc::Receiver<()>, in send_video_until_done() argument
/webrtc/webrtc/src/mux/
H A Dmod.rs98 mut closed_ch_rx: mpsc::Receiver<()>, in read_loop() argument
/webrtc/interceptor/src/report/sender/
H A Dmod.rs19 pub(crate) close_rx: Mutex<Option<mpsc::Receiver<()>>>,
/webrtc/util/src/vnet/
H A Dconn.rs34 read_ch_rx: Mutex<mpsc::Receiver<Box<dyn Chunk + Send + Sync>>>,
/webrtc/stun/src/
H A Dagent.rs265 pub(crate) async fn run(mut agent: Agent, mut rx: mpsc::Receiver<ClientAgent>) { in run()
/webrtc/interceptor/src/report/receiver/
H A Dmod.rs19 pub(crate) close_rx: Mutex<Option<mpsc::Receiver<()>>>,
/webrtc/webrtc/src/rtp_transceiver/rtp_receiver/
H A Dmod.rs110 async fn wait_for(rx: &mut watch::Receiver<State>, states: &[State]) -> Result<()> { in wait_for()
128 async fn error_on_close(rx: &mut watch::Receiver<State>) -> Result<()> { in error_on_close()
151 state_rx: watch::Receiver<State>,
/webrtc/interceptor/src/nack/generator/
H A Dmod.rs91 close_rx: Mutex<Option<mpsc::Receiver<()>>>,

12