Searched defs:receiver (Results 1 – 11 of 11) sorted by relevance
33 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_recv() localVariable71 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_to_recv_from() localVariable100 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_recv() localVariable147 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_try_recv_from() localVariable203 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_try_recv() localVariable241 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_block_on_try_recv() localVariable275 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_recv_poll() localVariable316 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_send_to_peek_from() localVariable350 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_send_to_try_peek_from() localVariable385 let receiver = UdpSocket::bind(ADDR) in sdv_udp_send_to_recv_from_poll() localVariable[all …]
24 receiver: UnixStream, field53 let mut receiver = Registry::get_instance() in initialize() localVariable75 let mut receiver = Registry::get_instance() in initialize() localVariable
70 receiver: UnixStream, field
404 let receiver = signal_return_watch(kind)?; in signal() localVariable
37 let receiver = match UdpSocket::bind(receiver_addr) { in sdv_send_recv() localVariable97 let receiver = match UdpSocket::bind(receiver_addr) { in sdv_send_to_recv_from() localVariable
162 let receiver = unsafe { UnixDatagram::from_raw_fd(fd) }; in sdv_uds_send_recv() localVariable
100 let receiver = UdpSocket::bind(receiver_addr).await.unwrap(); in ylong_udp_send_recv() localVariable141 let receiver = tokioUdpSocket::bind(receiver_addr.clone()).await.unwrap(); in tokio_udp_send_recv() localVariable187 let receiver = UdpSocket::bind(receiver_addr).await.unwrap(); in ylong_udp_send_to_recv_from() localVariable224 let receiver = tokioUdpSocket::bind(receiver_addr.clone()).await.unwrap(); in tokio_udp_send_to_recv_from() localVariable
1632 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_send_to_recv_from_poll() localVariable1735 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_send_to_peek_from() localVariable1769 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_send_to_try_peek_from() localVariable1803 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_send_to_peek_from_poll() localVariable1836 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_connected_peek() localVariable1874 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_connected_try_peek() localVariable
55 let receiver = self.get_mut(); in poll() localVariable
225 pub(crate) receiver: RespReceiver, field269 receiver: Option<BoundedReceiver<RespMessage>>, field
475 let receiver = UdpSocket::bind(ADDR).await.unwrap(); in ut_sleep_drop() localVariable