Searched refs:rtcp_writer (Results 1 – 6 of 6) sorted by relevance
| /webrtc/interceptor/src/mock/ |
| H A D | mock_stream.rs | 16 rtcp_writer: Mutex<Option<Arc<dyn RTCPWriter + Send + Sync>>>, field
49 rtcp_writer: Mutex::new(None), in new()
66 let rtcp_writer = interceptor in new() localVariable
70 let mut rw = stream.rtcp_writer.lock().await; in new()
71 *rw = Some(rtcp_writer); in new()
156 let rtcp_writer = self.rtcp_writer.lock().await; in write_rtcp() localVariable
157 if let Some(writer) = &*rtcp_writer { in write_rtcp()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | mod.rs | 45 rtcp_writer: Arc<dyn RTCPWriter + Send + Sync>, in run()
75 if let Err(err) = rtcp_writer.write(&[Box::new(pkt)], &a).await{ in run()
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | mod.rs | 83 rtcp_writer: Arc<dyn RTCPWriter + Send + Sync>, in run()
114 if let Err(err) = rtcp_writer.write(&[Box::new(pkt)], &a).await{ in run()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | mod.rs | 114 rtcp_writer: Arc<dyn RTCPWriter + Send + Sync>, in run()
151 if let Err(err) = rtcp_writer.write(&[Box::new(nack)], &a).await{ in run()
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | mod.rs | 95 rtcp_writer: Arc<dyn RTCPWriter + Send + Sync>, in run()
140 if let Err(err) = rtcp_writer.write(&pkts, &a).await{ in run()
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 361 rtcp_writer: writer, in bind_rtcp_writer()
610 rtcp_writer: Arc<dyn RTCPWriter + Send + Sync>, field
701 self.rtcp_writer.write(pkts, attributes).await in write()
|