Home
last modified time | relevance | path

Searched refs:Sender (Results 1 – 25 of 62) sorted by relevance

123

/webrtc/interceptor/src/twcc/sender/
H A Dmod.rs35 Ok(Arc::new(Sender { in build()
43 pub struct Sender { struct
48 impl Sender { argument
56 impl Interceptor for Sender { implementation
H A Dsender_test.rs13 let builder = Sender::builder().with_init_sequence_nr(0); in test_twcc_sender_interceptor()
/webrtc/dtls/src/flight/
H A Dmod.rs74 tx: &mut mpsc::Sender<mpsc::Sender<()>>, in parse() argument
H A Dflight2.rs30 tx: &mut mpsc::Sender<mpsc::Sender<()>>, in parse() argument
H A Dflight6.rs29 _tx: &mut mpsc::Sender<mpsc::Sender<()>>, in parse() argument
H A Dflight1.rs39 tx: &mut mpsc::Sender<mpsc::Sender<()>>, in parse() argument
H A Dflight0.rs29 _tx: &mut mpsc::Sender<mpsc::Sender<()>>, in parse() argument
/webrtc/interceptor/src/twcc/receiver/
H A Dreceiver_stream.rs7 packet_chan_tx: mpsc::Sender<Packet>,
17 packet_chan_tx: mpsc::Sender<Packet>, in new()
/webrtc/stun/src/
H A Dclient.rs30 client_agent_tx: Arc<mpsc::Sender<ClientAgent>>, in start()
37 close_tx: Option<mpsc::Sender<()>>,
44 client_agent_tx: Arc<mpsc::Sender<ClientAgent>>, in start()
215 close_tx: Option<mpsc::Sender<()>>,
216 client_agent_tx: Option<Arc<mpsc::Sender<ClientAgent>>>,
224 client_agent_tx: Arc<mpsc::Sender<ClientAgent>>, in read_until_closed()
282 client_agent_tx: Arc<mpsc::Sender<ClientAgent>>, in start()
/webrtc/srtp/src/session/
H A Dmod.rs35 close_stream_tx: mpsc::Sender<u32>,
36 close_session_tx: mpsc::Sender<()>,
133 close_stream_tx: &mpsc::Sender<u32>, in incoming()
134 new_stream_tx: &mut mpsc::Sender<Arc<Stream>>, in incoming()
186 close_stream_tx: mpsc::Sender<u32>, in get_or_create_stream()
/webrtc/srtp/src/
H A Dstream.rs16 tx: mpsc::Sender<u32>,
23 pub fn new(ssrc: u32, tx: mpsc::Sender<u32>, is_rtp: bool) -> Self { in new()
/webrtc/webrtc/src/api/interceptor_registry/
H A Dmod.rs12 use interceptor::twcc::{receiver::Receiver, sender::Sender};
96 let sender = Box::new(Sender::builder()); in configure_twcc()
125 let sender = Box::new(Sender::builder()); in configure_twcc_sender_only()
/webrtc/util/src/conn/
H A Dconn_udp_listener.rs27 accept_ch_tx: Arc<Mutex<Option<mpsc::Sender<Arc<UdpConn>>>>>,
28 done_ch_tx: Arc<Mutex<Option<watch::Sender<()>>>>,
145 accept_ch_tx: Arc<Mutex<Option<mpsc::Sender<Arc<UdpConn>>>>>, in read_loop()
191 accept_ch_tx: &Arc<Mutex<Option<mpsc::Sender<Arc<UdpConn>>>>>, in get_udp_conn()
/webrtc/turn/src/allocation/
H A Dmod.rs29 oneshot::{self, Sender},
81 reset_tx: SyncMutex<Option<mpsc::Sender<Duration>>>,
85 drop_tx: Option<Sender<u32>>,
86 alloc_close_notify: Option<mpsc::Sender<AllocationInfo>>,
101 alloc_close_notify: Option<mpsc::Sender<AllocationInfo>>, in new()
H A Dallocation_manager.rs17 pub alloc_close_notify: Option<mpsc::Sender<AllocationInfo>>,
25 alloc_close_notify: Option<mpsc::Sender<AllocationInfo>>,
H A Dpermission.rs15 reset_tx: Option<mpsc::Sender<Duration>>,
H A Dchannel_bind.rs18 reset_tx: Option<mpsc::Sender<Duration>>,
/webrtc/turn/src/server/
H A Dconfig.rs43 pub alloc_close_notify: Option<mpsc::Sender<AllocationInfo>>,
H A Dmod.rs35 command_tx: Mutex<Option<broadcast::Sender<Command>>>,
255 mpsc::Sender<HashMap<FiveTuple, AllocationInfo>>,
/webrtc/dtls/src/conn/
H A Dmod.rs53 type PacketSendRequest = (Vec<Packet>, Option<mpsc::Sender<Result<()>>>);
59 decrypted_tx: mpsc::Sender<Result<Vec<u8>>>,
65 handshake_tx: mpsc::Sender<mpsc::Sender<()>>,
67 packet_tx: Arc<mpsc::Sender<PacketSendRequest>>,
97 pub(crate) handshake_rx: mpsc::Receiver<mpsc::Sender<()>>,
99 pub(crate) packet_tx: Arc<mpsc::Sender<PacketSendRequest>>,
100 pub(crate) handle_queue_tx: mpsc::Sender<mpsc::Sender<()>>,
101 pub(crate) handshake_done_tx: Option<mpsc::Sender<()>>,
103 reader_close_tx: Mutex<Option<mpsc::Sender<()>>>,
749 handle_queue_rx: &mut mpsc::Receiver<mpsc::Sender<()>>, in read_and_buffer() argument
/webrtc/sctp/src/timer/
H A Dack_timer.rs19 pub(crate) close_tx: Option<mpsc::Sender<()>>,
/webrtc/interceptor/src/mock/
H A Dmock_stream.rs19 rtcp_out_modified_tx: mpsc::Sender<RTCPPackets>,
20 rtp_out_modified_tx: mpsc::Sender<rtp::packet::Packet>,
26 rtcp_in_tx: Mutex<Option<mpsc::Sender<RTCPPackets>>>,
27 rtp_in_tx: Mutex<Option<mpsc::Sender<rtp::packet::Packet>>>,
/webrtc/turn/src/client/
H A Dmod.rs73 read_ch_tx: Arc<Mutex<Option<mpsc::Sender<InboundData>>>>,
265 read_ch_tx: &Arc<Mutex<Option<mpsc::Sender<InboundData>>>>, in handle_inbound()
306 read_ch_tx: &Arc<Mutex<Option<mpsc::Sender<InboundData>>>>, in handle_stun_message()
375 read_ch_tx: &Arc<Mutex<Option<mpsc::Sender<InboundData>>>>, in handle_channel_data()
401 read_ch_tx: &Arc<Mutex<Option<mpsc::Sender<InboundData>>>>, in handle_inbound_relay_conn()
H A Dperiodic_timer.rs29 close_tx: Mutex<Option<mpsc::Sender<()>>>,
/webrtc/interceptor/src/stats/
H A Dinterceptor.rs33 chan: oneshot::Sender<Vec<Option<inbound::StatsSnapshot>>>,
37 chan: oneshot::Sender<Vec<Option<outbound::StatsSnapshot>>>,
91 tx: mpsc::Sender<Message>,
385 tx: mpsc::Sender<Message>,
611 tx: mpsc::Sender<Message>,
707 tx: mpsc::Sender<Message>,
711 fn new(rtp_reader: Arc<dyn RTPReader + Send + Sync>, tx: mpsc::Sender<Message>) -> Self { in new()
750 tx: mpsc::Sender<Message>,
754 fn new(rtp_writer: Arc<dyn RTPWriter + Send + Sync>, tx: mpsc::Sender<Message>) -> Self { in new()

123