| /webrtc/interceptor/ |
| H A D | README.md | 6 <a href="https://github.com/webrtc-rs/interceptor/actions"> 7 <img src="https://github.com/webrtc-rs/interceptor/workflows/cargo/badge.svg"> 9 <a href="https://codecov.io/gh/webrtc-rs/interceptor"> 10 <img src="https://codecov.io/gh/webrtc-rs/interceptor/branch/main/graph/badge.svg"> 12 <a href="https://deps.rs/repo/github/webrtc-rs/interceptor"> 13 <img src="https://deps.rs/repo/github/webrtc-rs/interceptor/status.svg"> 15 <a href="https://crates.io/crates/interceptor"> 16 <img src="https://img.shields.io/crates/v/interceptor.svg"> 18 <a href="https://docs.rs/interceptor"> 19 <img src="https://docs.rs/interceptor/badge.svg"> [all …]
|
| H A D | Cargo.toml | 2 name = "interceptor" 8 documentation = "https://docs.rs/interceptor" 10 repository = "https://github.com/webrtc-rs/interceptor"
|
| H A D | CHANGELOG.md | 1 # interceptor changelog 20 * [#14 Don't panic on seqnum rollover](https://github.com/webrtc-rs/interceptor/pull/14) contribute… 21 * Add stats interceptor. Contributed by [@k0nserv](https://github.com/k0nserv) in [#277](https://gi… 26 … not always, available in the [GitHub Releases](https://github.com/webrtc-rs/interceptor/releases).
|
| /webrtc/webrtc/src/track/ |
| H A D | mod.rs | 6 use interceptor::stream_info::StreamInfo; 7 use interceptor::{RTCPReader, RTPReader};
|
| /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() 150 interceptor, in new_rtp_receiver() 159 interceptor: Arc<dyn Interceptor + Send + Sync>, in new_rtp_sender() 166 interceptor, in new_rtp_sender()
|
| /webrtc/webrtc/src/api/interceptor_registry/ |
| H A D | mod.rs | 9 use interceptor::nack::{generator::Generator, responder::Responder}; 10 use interceptor::registry::Registry; 11 use interceptor::report::{receiver::ReceiverReport, sender::SenderReport}; 12 use interceptor::twcc::{receiver::Receiver, sender::Sender};
|
| /webrtc/interceptor/src/mock/ |
| H A D | mock_stream.rs | 14 interceptor: Arc<dyn Interceptor + Send + Sync>, field 37 interceptor: Arc<dyn Interceptor + Send + Sync>, in new() 47 interceptor: Arc::clone(&interceptor), in new() 66 let rtcp_writer = interceptor in new() 73 let rtp_writer = interceptor in new() 84 let rtcp_reader = interceptor in new() 114 let rtp_reader = interceptor in new() 243 self.interceptor.close().await in close()
|
| /webrtc/webrtc/src/peer_connection/sdp/ |
| H A D | sdp_test.rs | 567 let interceptor = api.interceptor_registry.build("")?; in test_media_description_fingerprints() localVariable 577 Arc::clone(&interceptor), in test_media_description_fingerprints() 582 Arc::clone(&interceptor), in test_media_description_fingerprints() 651 Arc::clone(&interceptor), in test_media_description_fingerprints() 677 let interceptor = api.interceptor_registry.build("")?; in test_populate_sdp() localVariable 683 Arc::clone(&interceptor), in test_populate_sdp() 762 let interceptor = api.interceptor_registry.build("")?; in test_populate_sdp() localVariable 767 Arc::clone(&interceptor), in test_populate_sdp() 869 let interceptor = api.interceptor_registry.build("")?; in test_populate_sdp_reject() localVariable 874 Arc::clone(&interceptor), in test_populate_sdp_reject() [all …]
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | mod.rs | 20 use interceptor::stream_info::RTPHeaderExtension; 21 use interceptor::{Attributes, Interceptor}; 159 interceptor: Arc<dyn Interceptor + Send + Sync>, field 410 interceptor: Arc<dyn Interceptor + Send + Sync>, in new() 425 interceptor, in new() 511 let (global_params, interceptor, media_engine) = { in receive() 514 Arc::clone(&self.internal.interceptor), in receive() 559 Arc::clone(&interceptor), in receive() 594 .streams_for_ssrc(rtx_ssrc, &stream_info, &interceptor) in receive() 719 .interceptor in stop() [all …]
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | mod.rs | 19 use interceptor::stream_info::StreamInfo; 20 use interceptor::{Attributes, Interceptor, RTCPReader, RTPWriter}; 102 pub(crate) interceptor: Arc<dyn Interceptor + Send + Sync>, field 137 interceptor: Arc<dyn Interceptor + Send + Sync>, in new() 169 let rtcp_interceptor = interceptor.bind_rtcp_reader(srtp_rtcp_reader).await; in new() 196 interceptor, in new() 424 .interceptor in send() 465 self.interceptor.unbind_local_stream(&stream_info).await; in stop()
|
| /webrtc/ |
| H A D | Cargo.toml | 8 "interceptor",
|
| /webrtc/webrtc/src/ |
| H A D | lib.rs | 8 pub use interceptor;
|
| H A D | error.rs | 402 Interceptor(#[from] interceptor::Error), 438 impl From<Error> for interceptor::Error { 441 interceptor::Error::Util(util::Error::from_std(e)) in from()
|
| /webrtc/webrtc/ |
| H A D | Cargo.toml | 20 interceptor = { version = "0.8.2", path = "../interceptor" }
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_internal.rs | 110 interceptor, in new() 207 let interceptor = self in start_rtp() localVariable 208 .interceptor in start_rtp() 217 interceptor, in start_rtp() 447 let interceptor = self in add_transceiver_from_kind() localVariable 448 .interceptor in add_transceiver_from_kind() 456 Arc::clone(&interceptor), in add_transceiver_from_kind() 465 interceptor, in add_transceiver_from_kind() 492 let interceptor = self in new_transceiver_from_track() localVariable 493 .interceptor in new_transceiver_from_track() [all …]
|
| H A D | mod.rs | 76 use interceptor::{stats, Attributes, Interceptor, RTCPWriter}; 192 interceptor: Arc<dyn Interceptor + Send + Sync>, field 224 let (interceptor, stats_interceptor): (Arc<dyn Interceptor + Send + Sync>, _) = { in new() 232 let weak_interceptor = Arc::downgrade(&interceptor); in new() 237 let interceptor_rtcp_writer = interceptor.bind_rtcp_writer(internal_rtcp_writer).await; in new() 250 interceptor, in new() 1378 Arc::clone(&self.interceptor), in set_remote_description() 1387 Arc::clone(&self.interceptor), in set_remote_description() 1903 if let Err(err) = self.interceptor.close().await { in close()
|
| /webrtc/webrtc/src/track/track_remote/ |
| H A D | mod.rs | 11 use interceptor::{Attributes, Interceptor}; 56 interceptor: Arc<dyn Interceptor + Send + Sync>, field 87 interceptor: Arc<dyn Interceptor + Send + Sync>, in new() 102 interceptor, in new()
|
| /webrtc/webrtc/src/dtls_transport/ |
| H A D | mod.rs | 12 use interceptor::stream_info::StreamInfo; 13 use interceptor::{Interceptor, RTCPReader, RTPReader}; 583 interceptor: &Arc<dyn Interceptor + Send + Sync>, in streams_for_ssrc() 597 let rtp_interceptor = interceptor in streams_for_ssrc() 608 let rtcp_interceptor = interceptor.bind_rtcp_reader(rtcp_stream_reader).await; in streams_for_ssrc()
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | rtp_transceiver_test.rs | 22 let interceptor = api.interceptor_registry.build("")?; in test_rtp_transceiver_set_codec_preferences() localVariable 27 Arc::clone(&interceptor), in test_rtp_transceiver_set_codec_preferences() 31 api.new_rtp_sender(None, Arc::clone(&transport), Arc::clone(&interceptor)) in test_rtp_transceiver_set_codec_preferences()
|
| H A D | srtp_writer_future.rs | 11 use interceptor::{Attributes, RTCPReader, RTPWriter}; 259 type IResult<T> = std::result::Result<T, interceptor::Error>;
|
| /webrtc/webrtc/src/track/track_local/ |
| H A D | mod.rs | 12 use interceptor::{Attributes, RTPWriter};
|
| /webrtc/interceptor/src/stats/ |
| H A D | mod.rs | 7 mod interceptor; module 9 pub use self::interceptor::StatsInterceptor;
|
| /webrtc/examples/examples/data-channels/ |
| H A D | data-channels.rs | 12 use webrtc::interceptor::registry::Registry;
|
| /webrtc/examples/examples/data-channels-create/ |
| H A D | data-channels-create.rs | 11 use webrtc::interceptor::registry::Registry;
|
| /webrtc/examples/examples/rtp-to-webrtc/ |
| H A D | rtp-to-webrtc.rs | 11 use webrtc::interceptor::registry::Registry;
|