58             internal: Arc::new(GeneratorInternal {  in build()
96     internal: Arc<GeneratorInternal>,  field
115         internal: Arc<GeneratorInternal>,  in run()
117         let mut ticker = tokio::time::interval(internal.interval);  in run()
119             let mut close_rx = internal.close_rx.lock().await;  in run()
133                         let streams = internal.streams.lock().await;  in run()
135                             let missing = stream.missing_seq_numbers(internal.skip_last_n);  in run()
190         let internal = Arc::clone(&self.internal);  in bind_rtcp_writer()  localVariable
193             if let Err(err) = Generator::run(writer2, internal).await {  in bind_rtcp_writer()
226             self.internal.log2_size_minus_6,  in bind_remote_stream()
230             let mut streams = self.internal.streams.lock().await;  in bind_remote_stream()
239         let mut receive_logs = self.internal.streams.lock().await;  in unbind_remote_stream()