| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | rtp_receiver_test.rs | 71 let (mut sender, mut receiver, wan) = create_vnet_pair().await?; in test_set_rtp_parameters()
89 receiver.on_track(Box::new(move |_, receiver, _| { in test_set_rtp_parameters()
92 receiver.set_rtp_parameters(P.clone()).await; in test_set_rtp_parameters()
94 if let Some(t) = receiver.track().await { in test_set_rtp_parameters()
131 until_connection_state(&mut receiver, &wg, RTCPeerConnectionState::Connected).await; in test_set_rtp_parameters()
133 signal_pair(&mut sender, &mut receiver).await?; in test_set_rtp_parameters()
156 close_pair_now(&sender, &receiver).await; in test_set_rtp_parameters()
165 let (mut sender, mut receiver, wan) = create_vnet_pair().await?; in test_rtp_receiver_set_read_deadline()
180 receiver.on_track(Box::new(move |track, receiver, _| { in test_rtp_receiver_set_read_deadline()
207 signal_pair(&mut sender, &mut receiver).await?; in test_rtp_receiver_set_read_deadline()
[all …]
|
| H A D | mod.rs | 503 let receiver = Arc::downgrade(&self.internal); in receive() localVariable
557 receiver.clone(), in receive()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | rtp_sender_test.rs | 61 receiver.on_track(Box::new(move |track, _, _| { in test_rtp_sender_replace_track()
88 signal_pair(&mut sender, &mut receiver).await?; in test_rtp_sender_replace_track()
118 close_pair_now(&sender, &receiver).await; in test_rtp_sender_replace_track()
171 &mut receiver, in test_rtp_sender_set_read_deadline()
177 signal_pair(&mut sender, &mut receiver).await?; in test_rtp_sender_set_read_deadline()
188 close_pair_now(&sender, &receiver).await; in test_rtp_sender_set_read_deadline()
223 signal_pair(&mut sender, &mut receiver).await?; in test_rtp_sender_replace_track_invalid_track_kind_change()
227 receiver.on_track(Box::new(move |_, _, _| { in test_rtp_sender_replace_track_invalid_track_kind_change()
250 close_pair_now(&sender, &receiver).await; in test_rtp_sender_replace_track_invalid_track_kind_change()
309 receiver.on_track(Box::new(move |_, _, _| { in test_rtp_sender_replace_track_invalid_codec_change()
[all …]
|
| /webrtc/webrtc/src/api/interceptor_registry/ |
| H A D | mod.rs | 11 use interceptor::report::{receiver::ReceiverReport, sender::SenderReport};
12 use interceptor::twcc::{receiver::Receiver, sender::Sender};
32 let receiver = Box::new(ReceiverReport::builder()); in configure_rtcp_reports() localVariable
34 registry.add(receiver); in configure_rtcp_reports()
97 let receiver = Box::new(Receiver::builder()); in configure_twcc() localVariable
99 registry.add(receiver); in configure_twcc()
165 let receiver = Box::new(Receiver::builder()); in configure_twcc_receiver_only() localVariable
166 registry.add(receiver); in configure_twcc_receiver_only()
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | mod.rs | 196 receiver: Arc<RTCRtpReceiver>, in new()
210 receiver: SyncMutex::new(receiver), in new()
280 let receiver = self.receiver.lock(); in receiver() localVariable
281 receiver.clone() in receiver()
288 let mut receiver = self.receiver.lock(); in set_receiver() localVariable
291 *receiver = r; in set_receiver()
399 let receiver = self.receiver.lock().clone(); in process_new_current_direction() localVariable
403 receiver.pause().await?; in process_new_current_direction()
405 receiver.resume().await?; in process_new_current_direction()
431 let r = self.receiver.lock(); in stop()
[all …]
|
| H A D | rtp_transceiver_test.rs | 24 let receiver = Arc::new(api.new_rtp_receiver( in test_rtp_transceiver_set_codec_preferences() localVariable
36 receiver, in test_rtp_transceiver_set_codec_preferences()
|
| /webrtc/webrtc/src/track/track_remote/ |
| H A D | mod.rs | 60 receiver: Option<Weak<RTPReceiverInternal>>, field
85 receiver: Weak<RTPReceiverInternal>, in new()
100 receiver: Some(receiver), in new()
232 let receiver = match self.receiver.as_ref().and_then(|r| r.upgrade()) { in read() localVariable
237 let (n, attributes) = receiver.read_rtp(b, self.tid).await?; in read()
257 if let Some(receiver) = &self.receiver { in check_and_update_track()
258 if let Some(receiver) = receiver.upgrade() { in check_and_update_track()
259 self.kind.store(receiver.kind as u8, Ordering::SeqCst); in check_and_update_track()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_internal.rs | 169 let receiver = t.receiver(); in start_rtp() localVariable
340 let receiver = t.receiver(); in start_rtp_receivers() localVariable
366 let receiver = t.receiver(); in start_rtp_receivers() localVariable
373 receiver, in start_rtp_receivers()
472 receiver, in add_transceiver_from_kind()
889 let receiver = t.receiver(); in handle_undeclared_ssrc() localVariable
893 receiver, in handle_undeclared_ssrc()
1007 let receiver = t.receiver(); in handle_incoming_ssrc() localVariable
1043 receiver, in handle_incoming_ssrc()
1071 let receiver = Arc::clone(&receiver); in start_receiver() localVariable
[all …]
|
| H A D | mod.rs | 584 receiver: Arc<RTCRtpReceiver>, in do_track()
592 f(track, receiver, transceiver).await; in do_track()
1373 let receiver = Arc::new(RTCRtpReceiver::new( in set_remote_description() localVariable
1394 receiver, in set_remote_description()
1657 receivers.push(transceiver.receiver()); in get_receivers()
|
| /webrtc/interceptor/src/report/ |
| H A D | mod.rs | 7 pub mod receiver; module
12 use receiver::{ReceiverReport, ReceiverReportInternal};
|
| /webrtc/webrtc/src/peer_connection/sdp/ |
| H A D | sdp_test.rs | 680 let receiver = Arc::new(api.new_rtp_receiver( in test_populate_sdp() localVariable
692 receiver, in test_populate_sdp()
764 let receiver = Arc::new(api.new_rtp_receiver( in test_populate_sdp() localVariable
776 receiver, in test_populate_sdp()
|
| /webrtc/interceptor/src/twcc/ |
| H A D | mod.rs | 4 pub mod receiver; module
|
| /webrtc/webrtc/ |
| H A D | CHANGELOG.md | 14 * Change `RTCPeerConnection::on_track` callback signature to `|track: Arc<TrackRemote>, receiver: A…
26 * Change `RTCRtpTransceiver::receiver` signature to `|&self| -> Arc<RTCRtpReceiver>` [#377](https:/…
43 - `receiver`.
|