| /webrtc/util/src/conn/ |
| H A D | conn_bridge_test.rs | 16 let n = conn0.send(&MSG1).await?; in test_bridge_normal()
24 let _ = tx.send(n).await; in test_bridge_normal()
40 let n = conn0.send(&MSG1).await?; in test_bridge_drop_1st_packet_from_conn0()
42 let n = conn0.send(&MSG2).await?; in test_bridge_drop_1st_packet_from_conn0()
50 let _ = tx.send(n).await; in test_bridge_drop_1st_packet_from_conn0()
67 let n = conn0.send(&MSG1).await?; in test_bridge_drop_2nd_packet_from_conn0()
77 let _ = tx.send(n).await; in test_bridge_drop_2nd_packet_from_conn0()
104 let _ = tx.send(n).await; in test_bridge_drop_1st_packet_from_conn1()
131 let _ = tx.send(n).await; in test_bridge_drop_2nd_packet_from_conn1()
170 let _ = tx.send(()).await; in test_bridge_reorder_packets_from_conn0()
[all …]
|
| H A D | conn_pipe_test.rs | 8 let n = c1.send(&b1).await?; in test_pipe()
16 let n = c2.send(&b2[..10]).await?; in test_pipe()
18 let n = c2.send(&b2[..5]).await?; in test_pipe()
|
| H A D | conn_udp.rs | 19 async fn send(&self, buf: &[u8]) -> Result<usize> { in send() method
20 Ok(self.send(buf).await?) in send()
|
| H A D | conn_udp_listener_test.rs | 25 d_conn.send(handshake.as_bytes()).await?; in pipe()
78 conn.send(&[i]).await?; in test_listener_close_unaccepted()
114 conn.send(packet).await?; in test_listener_accept_filter()
172 conn.send(&[i]).await?; in test_listener_concurrent()
|
| H A D | conn_pipe.rs | 51 async fn send(&self, b: &[u8]) -> Result<usize> { in send() method
53 match wr_tx.send(b.to_vec()).await { in send()
|
| /webrtc/stun/src/ |
| H A D | client.rs | 96 handler.send(e)?; in handle()
255 handler_tx.send(Event { in insert()
270 handler_tx.send(Event { in remove()
313 let _ = handler.send(event); in start()
330 .send(ClientAgent::Start(id, timeout)) in start()
336 let _ = handler.send(event); in start()
343 if c.send(&raw).await.is_err() { in start()
348 let _ = handler.send(event); in start()
451 .send(ClientAgent::Start(m.transaction_id, d)) in send()
457 let result = c.send(&m.raw).await; in send()
[all …]
|
| H A D | agent.rs | 135 handler.send(Event { in stop_with_error()
160 handler.send(e)?; in process()
179 handler.send(e)?; in close()
248 handler.send(event)?; in collect()
|
| /webrtc/rtp/src/extension/abs_send_time_extension/ |
| H A D | abs_send_time_extension_test.rs | 100 let send = AbsSendTimeExtension { in test_abs_send_time_extension_estimate() localVariable
103 let mut raw = BytesMut::with_capacity(send.marshal_size()); in test_abs_send_time_extension_estimate()
104 raw.resize(send.marshal_size(), 0); in test_abs_send_time_extension_estimate()
105 send.marshal_to(&mut raw)?; in test_abs_send_time_extension_estimate()
|
| /webrtc/examples/examples/ |
| H A D | README.md | 8 - [x] [Reflect](reflect): The reflect example demonstrates how to have webrtc-rs send back to the u…
9 …](play-from-disk-vpx): The play-from-disk-vp8 example demonstrates how to send VP8/VP9 video to yo…
10 …play-from-disk-h264): The play-from-disk-h264 example demonstrates how to send H264 video to your …
12 … The insertable-streams example demonstrates how webrtc-rs can be used to send E2E encrypted video…
22 - [x] [Data Channels](data-channels): The data-channels example shows how you can send/recv DataCha…
23 …te](data-channels-create): Example data-channels-create shows how you can send/recv DataChannel me…
25 …data-channels-detach): The data-channels-detach example shows how you can send/recv DataChannel me…
26 …els-detach-create): Example data-channels-detach-create shows how you can send/recv DataChannel me…
|
| /webrtc/interceptor/src/mock/ |
| H A D | mock_stream.rs | 95 let _ = rtcp_in_modified_tx.send(Err(err)).await; in new()
105 let _ = rtcp_in_modified_tx.send(Err(err.into())).await; in new()
110 let _ = rtcp_in_modified_tx.send(Ok(pkt)).await; in new()
128 let _ = rtp_in_modified_tx.send(Err(err)).await; in new()
138 let _ = rtp_in_modified_tx.send(Err(err.into())).await; in new()
143 let _ = rtp_in_modified_tx.send(Ok(pkt)).await; in new()
179 let _ = tx.send(pkts).await; in receive_rtcp()
187 let _ = tx.send(pkt).await; in receive_rtp()
254 let _ = self.rtcp_out_modified_tx.send(pkts.to_vec()).await; in write()
282 let _ = self.rtp_out_modified_tx.send(pkt.clone()).await; in write()
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | rtp_transceiver_direction.rs | 91 pub fn from_send_recv(send: bool, recv: bool) -> RTCRtpTransceiverDirection { in from_send_recv()
92 match (send, recv) { in from_send_recv()
182 for (expected_value, (send, recv)) in tests { in test_rtp_transceiver_from_send_recv()
184 RTCRtpTransceiverDirection::from_send_recv(send, recv), in test_rtp_transceiver_from_send_recv()
|
| /webrtc/examples/examples/data-channels-flow-control/ |
| H A D | README.md | 15 Send or SendText methods are called on DataChannel to send data to the connected peer.
19 When you have a large amount of data to send, it is an application's responsibility to
23 The rate you wish to send data might be much higher than the rate the data channel can
24 actually send to the peer over the Internet. The above properties/methods help your
|
| H A D | data-channels-flow-control.rs | 82 if shared_dc.send(&buf).await.is_err() { in create_requester()
105 more_can_be_sent.send(()).await.unwrap(); in create_requester()
210 fault.send(()).await.unwrap(); in main()
221 fault.send(()).await.unwrap(); in main()
|
| /webrtc/mdns/examples/ |
| H A D | mdns_server_query.rs | 35 a.send(()).await in main()
45 a.send(()).await in main()
|
| /webrtc/util/src/vnet/conn/ |
| H A D | conn_test.rs | 20 tx.send(Box::new(chunk)) in write()
94 let _ = rcvd_ch_tx.send(()).await; in test_udp_conn_send_to_recv_from()
179 let _ = rcvd_ch_tx.send(()).await; in test_udp_conn_send_recv()
185 let n = conn.send(&data).await.unwrap(); in test_udp_conn_send_recv()
|
| /webrtc/examples/examples/reflect/ |
| H A D | README.md | 3 reflect demonstrates how with one PeerConnection you can send video to webrtc-rs and have the packe…
36 Your browser should send video to webrtc-rs, and then it will be relayed right back to you.
|
| /webrtc/webrtc/src/mux/ |
| H A D | endpoint.rs | 53 async fn send(&self, buf: &[u8]) -> Result<usize> { in send() method
54 self.next_conn.send(buf).await in send()
|
| /webrtc/webrtc/src/data_channel/ |
| H A D | data_channel_test.rs | 159 let _ = done_tx3.send(()).await; in test_data_channel_open()
669 let _ = out_tx2.send(s).await; in test_data_channel_messages_are_ordered()
700 let _ = out_tx2.send(s).await; in test_data_channel_messages_are_ordered()
876 matches!(dc3.send(&buf).await, Ok(_)), in test_data_channel_buffered_amount_set_before_open()
977 matches!(dc3.send(&buf).await, Ok(_)), in test_data_channel_buffered_amount_set_after_open()
1042 let _ = dc_chan_tx3.send(detached).await; in test_eof_detach()
1079 let _ = open_tx2.send(()).await; in test_eof_detach()
1147 let _ = dcb_closed_ch_tx3.send(()).await; in test_eof_no_detach()
1181 let _ = dca_closed_ch_tx2.send(()).await; in test_eof_no_detach()
1431 let _ = await_setup_tx2.send(()).await; in test_data_channel_ortc_e2e()
[all …]
|
| /webrtc/turn/src/server/ |
| H A D | mod.rs | 90 tx.send(Command::DeleteAllocations(username, Arc::new(closed_rx))) in delete_allocations_by_username()
128 tx.send(Command::GetAllocationsInfo(five_tuples, infos_tx)) in get_allocations_info()
170 let _ = tx.send(infos).await; in read_loop()
234 let _ = tx.send(Command::Close(Arc::new(closed_rx))); in close()
|
| /webrtc/examples/examples/simulcast/ |
| H A D | README.md | 5 The browser will not send higher quality streams unless it has the available bandwidth. You can loo…
40 Your browser should send a simulcast track to WebRTC.rs, and then all 3 incoming streams will be re…
|
| /webrtc/examples/examples/data-channels/ |
| H A D | README.md | 3 data-channels is a WebRTC.rs application that shows how you can send/recv DataChannel messages from…
40 WebRTC.rs will send random messages every 5 seconds that will appear in your browser.
|
| /webrtc/examples/examples/data-channels-detach/ |
| H A D | README.md | 3 data-channels is a WebRTC.rs application that shows how you can send/recv DataChannel messages from…
40 WebRTC.rs will send random messages every 5 seconds that will appear in your browser.
|
| /webrtc/ice/examples/ |
| H A D | ping_pong.rs | 52 let _ = tx.send(full_body).await; in remote_handler()
67 let _ = tx.send(full_body).await; in remote_handler()
341 result = conn_tx.send(val.as_bytes()) => { in main()
394 let _ = done_tx.send(()); in main()
398 let _ = done_tx.send(()); in main()
|
| /webrtc/srtp/src/session/ |
| H A D | session_rtcp_test.rs | 218 sa.udp_tx.send(packet).await?; in test_session_srtcp_replay_protection()
221 sa.udp_tx.send(packet).await?; in test_session_srtcp_replay_protection()
225 sa.udp_tx.send(packet).await?; in test_session_srtcp_replay_protection()
|
| /webrtc/examples/examples/data-channels-create/ |
| H A D | README.md | 3 data-channels-create is a WebRTC.rs application that shows how you can send/recv DataChannel messag…
36 WebRTC.rs will send random messages every 5 seconds that will appear in your browser.
|