Searched refs:rtp_interceptor (Results 1 – 5 of 5) sorted by relevance
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | mod.rs | 261 let mut rtp_interceptor = None; in read_rtp() localVariable
267 rtp_interceptor = t.stream.rtp_interceptor.clone(); in read_rtp()
279 if let Some(rtp_interceptor) = rtp_interceptor { in read_rtp()
296 result = rtp_interceptor.read(b, &a) => { in read_rtp()
535 let (rtp_read_stream, rtp_interceptor, rtcp_read_stream, rtcp_interceptor) = in receive()
543 Some(rtp_interceptor), in receive()
564 rtp_interceptor, in receive()
572 rtp_interceptor: None, in receive()
592 let (rtp_read_stream, rtp_interceptor, rtcp_read_stream, rtcp_interceptor) = self in receive()
603 rtp_interceptor: Some(rtp_interceptor), in receive()
[all …]
|
| /webrtc/webrtc/src/track/ |
| H A D | mod.rs | 17 pub(crate) rtp_interceptor: Option<Arc<dyn RTPReader + Send + Sync>>, field
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_internal.rs | 978 let (rtp_read_stream, rtp_interceptor, rtcp_read_stream, rtcp_interceptor) = self in handle_incoming_ssrc()
986 let (n, _) = rtp_interceptor.read(&mut buf, &a).await?; in handle_incoming_ssrc()
1017 rtp_interceptor: Some(rtp_interceptor), in handle_incoming_ssrc()
1032 rtp_interceptor: Some(rtp_interceptor), in handle_incoming_ssrc()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | mod.rs | 423 let rtp_interceptor = self in send() localVariable
429 *interceptor_rtp_writer = Some(rtp_interceptor); in send()
|
| /webrtc/webrtc/src/dtls_transport/ |
| H A D | mod.rs | 597 let rtp_interceptor = interceptor in streams_for_ssrc() localVariable
612 rtp_interceptor, in streams_for_ssrc()
|