| /webrtc/interceptor/src/ |
| H A D | chain.rs | 10 interceptors: Vec<Arc<dyn Interceptor + Send + Sync>>, 15 pub fn new(interceptors: Vec<Arc<dyn Interceptor + Send + Sync>>) -> Self { in new() 19 pub fn add(&mut self, icpr: Arc<dyn Interceptor + Send + Sync>) { in add() 25 impl Interceptor for Chain {
|
| H A D | registry.rs | 4 use crate::{Interceptor, InterceptorBuilder}; 25 pub fn build(&self, id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build() 31 .map(|c| Arc::new(c) as Arc<dyn Interceptor + Send + Sync>) in build()
|
| H A D | noop.rs | 10 impl Interceptor for NoOp {
|
| H A D | lib.rs | 32 fn build(&self, id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>>; in build() 38 pub trait Interceptor { trait
|
| /webrtc/interceptor/src/mock/ |
| H A D | mock_builder.rs | 2 use crate::{Interceptor, InterceptorBuilder}; 5 pub type MockBuilderResult = Result<Arc<dyn Interceptor + Send + Sync>>;
|
| H A D | mock_stream.rs | 3 use crate::{Attributes, Interceptor, RTCPReader, RTCPWriter, RTPReader, RTPWriter}; 14 interceptor: Arc<dyn Interceptor + Send + Sync>, 37 interceptor: Arc<dyn Interceptor + Send + Sync>, in new()
|
| H A D | mock_interceptor.rs | 59 impl Interceptor for MockInterceptor {
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | receiver_test.rs | 16 let icpr: Arc<dyn Interceptor + Send + Sync> = ReceiverReport::builder() in test_receiver_interceptor_before_any_packet() 68 let icpr: Arc<dyn Interceptor + Send + Sync> = ReceiverReport::builder() in test_receiver_interceptor_after_rtp_packets() 133 let icpr: Arc<dyn Interceptor + Send + Sync> = ReceiverReport::builder() in test_receiver_interceptor_after_rtp_and_rtcp_packets() 217 let icpr: Arc<dyn Interceptor + Send + Sync> = ReceiverReport::builder() in test_receiver_interceptor_overflow() 291 let icpr: Arc<dyn Interceptor + Send + Sync> = ReceiverReport::builder() in test_receiver_interceptor_overflow_five_pkts() 393 let icpr: Arc<dyn Interceptor + Send + Sync> = ReceiverReport::builder() in test_receiver_interceptor_packet_loss() 504 let icpr: Arc<dyn Interceptor + Send + Sync> = ReceiverReport::builder() in test_receiver_interceptor_overflow_and_packet_loss() 574 let icpr: Arc<dyn Interceptor + Send + Sync> = ReceiverReport::builder() in test_receiver_interceptor_reordered_packets() 636 let icpr: Arc<dyn Interceptor + Send + Sync> = ReceiverReport::builder() in test_receiver_interceptor_jitter() 716 let icpr: Arc<dyn Interceptor + Send + Sync> = ReceiverReport::builder() in test_receiver_interceptor_delay()
|
| H A D | mod.rs | 128 impl Interceptor for ReceiverReport {
|
| /webrtc/interceptor/src/report/ |
| H A D | mod.rs | 11 use crate::{Interceptor, InterceptorBuilder}; 78 fn build(&self, _id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build()
|
| /webrtc/webrtc/src/api/ |
| H A D | mod.rs | 27 use interceptor::{registry::Registry, Interceptor}; 143 interceptor: Arc<dyn Interceptor + Send + Sync>, in new_rtp_receiver() 159 interceptor: Arc<dyn Interceptor + Send + Sync>, in new_rtp_sender()
|
| /webrtc/interceptor/src/twcc/sender/ |
| H A D | mod.rs | 34 fn build(&self, _id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build() 56 impl Interceptor for Sender {
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | mod.rs | 7 Attributes, Interceptor, InterceptorBuilder, RTCPReader, RTCPWriter, RTPReader, RTPWriter, 38 fn build(&self, _id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build() 137 impl Interceptor for Responder {
|
| H A D | responder_test.rs | 11 let icpr: Arc<dyn Interceptor + Send + Sync> = in test_responder_interceptor()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | mod.rs | 9 use crate::{Attributes, Interceptor, RTCPReader, RTPReader, RTPWriter}; 55 fn build(&self, _id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build() 165 impl Interceptor for Generator {
|
| H A D | generator_test.rs | 11 let icpr: Arc<dyn Interceptor + Send + Sync> = Generator::builder() in test_generator_interceptor()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | sender_test.rs | 16 let icpr: Arc<dyn Interceptor + Send + Sync> = SenderReport::builder() in test_sender_interceptor_before_any_packet() 68 let icpr: Arc<dyn Interceptor + Send + Sync> = SenderReport::builder() in test_sender_interceptor_after_rtp_packets() 132 let icpr: Arc<dyn Interceptor + Send + Sync> = SenderReport::builder() in test_sender_interceptor_after_rtp_packets_overflow()
|
| H A D | mod.rs | 89 impl Interceptor for SenderReport {
|
| /webrtc/webrtc/src/track/track_remote/ |
| H A D | mod.rs | 11 use interceptor::{Attributes, Interceptor}; 56 interceptor: Arc<dyn Interceptor + Send + Sync>, 87 interceptor: Arc<dyn Interceptor + Send + Sync>, in new()
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | mod.rs | 32 fn build(&self, _id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build() 150 impl Interceptor for Receiver {
|
| /webrtc/interceptor/ |
| H A D | README.md | 29 …rite <a href="https://github.com/pion/interceptor/releases/tag/v0.1.0">Pion</a> Interceptor in Rust
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | mod.rs | 20 use interceptor::{Attributes, Interceptor, RTCPReader, RTPWriter}; 102 pub(crate) interceptor: Arc<dyn Interceptor + Send + Sync>, 137 interceptor: Arc<dyn Interceptor + Send + Sync>, in new()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | mod.rs | 21 use interceptor::{Attributes, Interceptor}; 159 interceptor: Arc<dyn Interceptor + Send + Sync>, 410 interceptor: Arc<dyn Interceptor + Send + Sync>, in new()
|
| /webrtc/webrtc/src/ |
| H A D | error.rs | 402 Interceptor(#[from] interceptor::Error), enumerator
|
| /webrtc/webrtc/src/dtls_transport/ |
| H A D | mod.rs | 13 use interceptor::{Interceptor, RTCPReader, RTPReader}; 583 interceptor: &Arc<dyn Interceptor + Send + Sync>, in streams_for_ssrc()
|