Lines Matching refs:internal
24 pub(crate) internal: Arc<SenderReportInternal>, field
46 internal: Arc<SenderReportInternal>, in run()
48 let mut ticker = tokio::time::interval(internal.interval); in run()
50 let mut close_rx = internal.close_rx.lock().await; in run()
62 let now = if let Some(f) = &internal.now { in run()
68 let m = internal.streams.lock().await; in run()
114 let internal = Arc::clone(&self.internal); in bind_rtcp_writer() localVariable
117 if let Err(err) = SenderReport::run(writer2, internal).await { in bind_rtcp_writer()
136 self.internal.now.clone(), in bind_local_stream()
139 let mut streams = self.internal.streams.lock().await; in bind_local_stream()
148 let mut streams = self.internal.streams.lock().await; in unbind_local_stream()