• Home
  • Raw
  • Download

Lines Matching refs:sender

15     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in send_recv()  localVariable
18 sender.connect(receiver.local_addr()?).await?; in send_recv()
19 receiver.connect(sender.local_addr()?).await?; in send_recv()
21 sender.send(MSG).await?; in send_recv()
32 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_recv_poll() localVariable
35 sender.connect(receiver.local_addr()?).await?; in send_recv_poll()
36 receiver.connect(sender.local_addr()?).await?; in send_recv_poll()
38 poll_fn(|cx| sender.poll_send(cx, MSG)).await?; in send_recv_poll()
50 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_to_recv_from() localVariable
54 sender.send_to(MSG, &receiver_addr).await?; in send_to_recv_from()
60 assert_eq!(addr, sender.local_addr()?); in send_to_recv_from()
66 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_to_recv_from_poll() localVariable
70 poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?; in send_to_recv_from_poll()
77 assert_eq!(addr, sender.local_addr()?); in send_to_recv_from_poll()
83 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_to_peek_from() localVariable
87 poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?; in send_to_peek_from()
93 assert_eq!(addr, sender.local_addr()?); in send_to_peek_from()
99 assert_eq!(addr, sender.local_addr()?); in send_to_peek_from()
104 assert_eq!(addr, sender.local_addr()?); in send_to_peek_from()
111 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_to_peek_from_poll() localVariable
115 poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?; in send_to_peek_from_poll()
122 assert_eq!(addr, sender.local_addr()?); in send_to_peek_from_poll()
177 let sender = UdpSocket::bind("127.0.0.1:0").await?; in split_chan() localVariable
178 sender.send_to(MSG, addr).await?; in split_chan()
180 let (len, _) = sender.recv_from(&mut recv_buf).await?; in split_chan()
212 let sender = UdpSocket::bind("127.0.0.1:0").await?; in split_chan_poll() localVariable
213 poll_fn(|cx| sender.poll_send_to(cx, MSG, addr)).await?; in split_chan_poll()
217 let _ = poll_fn(|cx| sender.poll_recv_from(cx, &mut read)).await?; in split_chan_poll()
235 let sender = UdpSocket::bind("127.0.0.1:0").await.unwrap(); in try_send_spawn() localVariable
239 .connect(sender.local_addr().unwrap()) in try_send_spawn()
243 sender.writable().await.unwrap(); in try_send_spawn()
245 let sent = &sender in try_send_spawn()
252 sender in try_send_spawn()
256 let sent = &sender.try_send(MSG2).unwrap(); in try_send_spawn()
261 let sent = &sender.try_send(MSG).unwrap(); in try_send_spawn()