Lines Matching refs:internal
23 pub(crate) internal: Arc<ReceiverReportInternal>, field
35 let now = if let Some(f) = &self.internal.now { in read()
47 let m = self.internal.streams.lock().await; in read()
62 pub(crate) internal: Arc<ReceiverReportInternal>, field
84 internal: Arc<ReceiverReportInternal>, in run()
86 let mut ticker = tokio::time::interval(internal.interval); in run()
88 let mut close_rx = internal.close_rx.lock().await; in run()
101 let now = if let Some(f) = &internal.now { in run()
107 let m = internal.streams.lock().await; in run()
136 internal: Arc::clone(&self.internal), in bind_rtcp_reader()
156 let internal = Arc::clone(&self.internal); in bind_rtcp_writer() localVariable
159 if let Err(err) = ReceiverReport::run(writer2, internal).await { in bind_rtcp_writer()
191 self.internal.now.clone(), in bind_remote_stream()
194 let mut streams = self.internal.streams.lock().await; in bind_remote_stream()
203 let mut streams = self.internal.streams.lock().await; in unbind_remote_stream()