91     tx: mpsc::Sender<Message>,  field
99         let (tx, rx) = mpsc::channel(100);  in new()
107             tx,  in new()
116         let (tx, rx) = mpsc::channel(100);  in with_time_gen()
123             tx,  in with_time_gen()
132         let (tx, rx) = oneshot::channel();  in fetch_inbound_stats()
135             .tx  in fetch_inbound_stats()
136             .send(Message::RequestInboundSnapshot { ssrcs, chan: tx })  in fetch_inbound_stats()
154         let (tx, rx) = oneshot::channel();  in fetch_outbound_stats()
157             .tx  in fetch_outbound_stats()
158             .send(Message::RequestOutboundSnapshot { ssrcs, chan: tx })  in fetch_outbound_stats()
313             .or_insert_with(|| Arc::new(RTPReadRecorder::new(reader, self.tx.clone())));  in bind_remote_stream()
336             .or_insert_with(|| Arc::new(RTPWriteRecorder::new(writer, self.tx.clone())));  in bind_local_stream()
362             tx: self.tx.clone(),  in bind_rtcp_writer()
377             tx: self.tx.clone(),  in bind_rtcp_reader()
385     tx: mpsc::Sender<Message>,  field
553                 .tx  in read()
565                 self.tx.send(Message::StatUpdate {  in read()
589                 self.tx.send(Message::StatUpdate {  in read()
611     tx: mpsc::Sender<Message>,  field
679                 .tx  in write()
692                     .tx  in write()
707     tx: mpsc::Sender<Message>,  field
711     fn new(rtp_reader: Arc<dyn RTPReader + Send + Sync>, tx: mpsc::Sender<Message>) -> Self {  in new()
712         Self { rtp_reader, tx }  in new()
732             .tx  in read()
750     tx: mpsc::Sender<Message>,  field
754     fn new(rtp_writer: Arc<dyn RTPWriter + Send + Sync>, tx: mpsc::Sender<Message>) -> Self {  in new()
755         Self { rtp_writer, tx }  in new()
772             .tx  in write()