Home
last modified time | relevance | path

Searched defs:receiver (Results 1 – 6 of 6) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
Dudp_test.rs39 let receiver = match UdpSocket::bind(receiver_addr).await { in sdv_udp_send_recv() localVariable
95 let receiver = match UdpSocket::bind(receiver_addr).await { in sdv_udp_send_to_recv_from() localVariable
162 let receiver = match UdpSocket::bind(receiver_addr).await { in sdv_udp_recv() localVariable
204 let receiver = match UdpSocket::bind(receiver_addr).await { in sdv_udp_try_recv_from() localVariable
284 let receiver = match UdpSocket::bind(receiver_addr).await { in sdv_udp_try_recv() localVariable
325 let receiver = match UdpSocket::bind(receiver_addr).await { in sdv_block_on_udp_try_recv() localVariable
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
Dudp_socket_test.rs37 let receiver = match UdpSocket::bind(receiver_addr) { in test_send_recv() localVariable
97 let receiver = match UdpSocket::bind(receiver_addr) { in test_send_to_recv_from() localVariable
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
Dylong_tokio_udp.rs98 let receiver = UdpSocket::bind(receiver_addr).await.unwrap(); in ylong_udp_send_recv() localVariable
139 let receiver = tokioUdpSocket::bind(receiver_addr.clone()).await.unwrap(); in tokio_udp_send_recv() localVariable
184 let receiver = UdpSocket::bind(receiver_addr).await.unwrap(); in ylong_udp_send_to_recv_from() localVariable
221 let receiver = tokioUdpSocket::bind(receiver_addr.clone()).await.unwrap(); in tokio_udp_send_to_recv_from() localVariable
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
Dudp.rs1470 let receiver = UdpSocket::bind(receiver_addr).await.unwrap(); in ut_udp_basic_v4() localVariable
1517 let receiver = UdpSocket::bind(receiver_addr).await.unwrap(); in ut_udp_basic_v6() localVariable
1549 let receiver = match UdpSocket::bind(receiver_addr).await { in test_send_recv_poll() localVariable
1610 let receiver = match UdpSocket::bind(receiver_addr).await { in test_send_to_recv_from_poll() localVariable
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
Dwheel.rs369 let receiver = UdpSocket::bind(receiver_addr).await.unwrap(); in ut_sleep_drop() localVariable
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
Ddispatcher.rs207 pub(crate) receiver: FrameReceiver, field
296 receiver: Option<UnboundedReceiver<Frame>>, field