Lines Matching refs:internal
36 internal: Arc::new(ReceiverInternal { in build()
73 internal: Arc<ReceiverInternal>, field
96 internal: Arc<ReceiverInternal>, in run()
99 let mut close_rx = internal.close_rx.lock().await; in run()
107 let mut packet_chan_rx = internal.packet_chan_rx.lock().await; in run()
116 let mut ticker = tokio::time::interval(internal.interval); in run()
125 let mut recorder = internal.recorder.lock().await; in run()
132 let mut recorder = internal.recorder.lock().await; in run()
171 let mut recorder = self.internal.recorder.lock().await; in bind_rtcp_writer()
180 let internal = Arc::clone(&self.internal); in bind_rtcp_writer() localVariable
183 if let Err(err) = Receiver::run(writer2, internal).await { in bind_rtcp_writer()
232 let mut streams = self.internal.streams.lock().await; in bind_remote_stream()
241 let mut streams = self.internal.streams.lock().await; in unbind_remote_stream()