16     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in send_recv()
17     let receiver = UdpSocket::bind("127.0.0.1:0").await?;  in send_recv()
19     sender.connect(receiver.local_addr()?).await?;  in send_recv()
20     receiver.connect(sender.local_addr()?).await?;  in send_recv()
22     sender.send(MSG).await?;  in send_recv()
25     let len = receiver.recv(&mut recv_buf[..]).await?;  in send_recv()
33     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in send_recv_poll()
34     let receiver = UdpSocket::bind("127.0.0.1:0").await?;  in send_recv_poll()
36     sender.connect(receiver.local_addr()?).await?;  in send_recv_poll()
37     receiver.connect(sender.local_addr()?).await?;  in send_recv_poll()
39     poll_fn(|cx| sender.poll_send(cx, MSG)).await?;  in send_recv_poll()
43     poll_fn(|cx| receiver.poll_recv(cx, &mut read)).await?;  in send_recv_poll()
51     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in send_to_recv_from()
52     let receiver = UdpSocket::bind("127.0.0.1:0").await?;  in send_to_recv_from()
55     sender.send_to(MSG, &receiver_addr).await?;  in send_to_recv_from()
58     let (len, addr) = receiver.recv_from(&mut recv_buf[..]).await?;  in send_to_recv_from()
67     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in send_to_recv_from_poll()
68     let receiver = UdpSocket::bind("127.0.0.1:0").await?;  in send_to_recv_from_poll()
71     poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?;  in send_to_recv_from_poll()
75     let addr = poll_fn(|cx| receiver.poll_recv_from(cx, &mut read)).await?;  in send_to_recv_from_poll()
84     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in send_to_peek_from()
85     let receiver = UdpSocket::bind("127.0.0.1:0").await?;  in send_to_peek_from()
88     poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?;  in send_to_peek_from()
92     let (n, addr) = receiver.peek_from(&mut recv_buf).await?;  in send_to_peek_from()
98     let (n, addr) = receiver.peek_from(&mut recv_buf).await?;  in send_to_peek_from()
103     let (n, addr) = receiver.recv_from(&mut recv_buf).await?;  in send_to_peek_from()
112     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in send_to_try_peek_from()
113     let receiver = UdpSocket::bind("127.0.0.1:0").await?;  in send_to_try_peek_from()
116     poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?;  in send_to_try_peek_from()
129                 receiver.readable().await?;  in send_to_try_peek_from()
137     let (n, addr) = receiver.peek_from(&mut recv_buf).await?;  in send_to_try_peek_from()
142     let (n, addr) = receiver.recv_from(&mut recv_buf).await?;  in send_to_try_peek_from()
151     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in send_to_peek_from_poll()
152     let receiver = UdpSocket::bind("127.0.0.1:0").await?;  in send_to_peek_from_poll()
155     poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?;  in send_to_peek_from_poll()
159     let addr = poll_fn(|cx| receiver.poll_peek_from(cx, &mut read)).await?;  in send_to_peek_from_poll()
166     poll_fn(|cx| receiver.poll_peek_from(cx, &mut read)).await?;  in send_to_peek_from_poll()
172     poll_fn(|cx| receiver.poll_recv_from(cx, &mut read)).await?;  in send_to_peek_from_poll()
179     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in peek_sender()
180     let receiver = UdpSocket::bind("127.0.0.1:0").await?;  in peek_sender()
186     sender.send_to(msg, receiver_addr).await?;  in peek_sender()
188     let peeked_sender = receiver.peek_sender().await?;  in peek_sender()
194     let (read, received_sender) = receiver.recv_from(&mut recv_buf).await?;  in peek_sender()
204     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in poll_peek_sender()
205     let receiver = UdpSocket::bind("127.0.0.1:0").await?;  in poll_peek_sender()
211     poll_fn(|cx| sender.poll_send_to(cx, msg, receiver_addr)).await?;  in poll_peek_sender()
213     let peeked_sender = poll_fn(|cx| receiver.poll_peek_sender(cx)).await?;  in poll_peek_sender()
220     let received_sender = poll_fn(|cx| receiver.poll_recv_from(cx, &mut read)).await?;  in poll_peek_sender()
230     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in try_peek_sender()
231     let receiver = UdpSocket::bind("127.0.0.1:0").await?;  in try_peek_sender()
237     sender.send_to(msg, receiver_addr).await?;  in try_peek_sender()
243                 receiver.readable().await?;  in try_peek_sender()
265     let socket = UdpSocket::bind("127.0.0.1:0").await?;  in split()
271         s.send_to(MSG, &addr).await.unwrap();  in split()
274     let (len, _) = r.recv_from(&mut recv_buf[..]).await?;  in split()
282     let socket = UdpSocket::bind("127.0.0.1:0").await?;  in split_chan()
289         while let Some((bytes, addr)) = rx.recv().await {  in split_chan()
290             s.send_to(&bytes, &addr).await.unwrap();  in split_chan()
297             let (len, addr) = r.recv_from(&mut buf).await.unwrap();  in split_chan()
298             tx.send((buf[..len].to_vec(), addr)).await.unwrap();  in split_chan()
303     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in split_chan()
304     sender.send_to(MSG, addr).await?;  in split_chan()
306     let (len, _) = sender.recv_from(&mut recv_buf).await?;  in split_chan()
314     let socket = UdpSocket::bind("127.0.0.1:0").await?;  in split_chan_poll()
321         while let Some((bytes, addr)) = rx.recv().await {  in split_chan_poll()
323                 .await  in split_chan_poll()
332             let addr = poll_fn(|cx| r.poll_recv_from(cx, &mut read)).await.unwrap();  in split_chan_poll()
333             tx.send((read.filled().to_vec(), addr)).await.unwrap();  in split_chan_poll()
338     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in split_chan_poll()
339     poll_fn(|cx| sender.poll_send_to(cx, MSG, addr)).await?;  in split_chan_poll()
343     let _ = poll_fn(|cx| sender.poll_recv_from(cx, &mut read)).await?;  in split_chan_poll()
361     let sender = UdpSocket::bind("127.0.0.1:0").await.unwrap();  in try_send_spawn()
362     let receiver = UdpSocket::bind("127.0.0.1:0").await.unwrap();  in try_send_spawn()
366         .await  in try_send_spawn()
369     sender.writable().await.unwrap();  in try_send_spawn()
376     let mut received = receiver.recv(&mut buf[..]).await.unwrap();  in try_send_spawn()
380         .await  in try_send_spawn()
384     received += receiver.recv(&mut buf[..]).await.unwrap();  in try_send_spawn()
392     received += receiver.recv(&mut buf[..]).await.unwrap();  in try_send_spawn()
400     let server = UdpSocket::bind("127.0.0.1:0").await.unwrap();  in try_send_recv()
403     let client = UdpSocket::bind("127.0.0.1:0").await.unwrap();  in try_send_recv()
406     client.connect(server.local_addr().unwrap()).await.unwrap();  in try_send_recv()
407     server.connect(client.local_addr().unwrap()).await.unwrap();  in try_send_recv()
411             client.writable().await.unwrap();  in try_send_recv()
424             server.readable().await.unwrap();  in try_send_recv()
444     let server = UdpSocket::bind("127.0.0.1:0").await.unwrap();  in try_send_to_recv_from()
448     let client = UdpSocket::bind("127.0.0.1:0").await.unwrap();  in try_send_to_recv_from()
453             client.writable().await.unwrap();  in try_send_to_recv_from()
466             server.readable().await.unwrap();  in try_send_to_recv_from()
487     let server = UdpSocket::bind("127.0.0.1:0").await.unwrap();  in try_recv_buf()
490     let client = UdpSocket::bind("127.0.0.1:0").await.unwrap();  in try_recv_buf()
493     client.connect(server.local_addr().unwrap()).await.unwrap();  in try_recv_buf()
494     server.connect(client.local_addr().unwrap()).await.unwrap();  in try_recv_buf()
498             client.writable().await.unwrap();  in try_recv_buf()
511             server.readable().await.unwrap();  in try_recv_buf()
530     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in recv_buf()
531     let receiver = UdpSocket::bind("127.0.0.1:0").await?;  in recv_buf()
533     sender.connect(receiver.local_addr()?).await?;  in recv_buf()
534     receiver.connect(sender.local_addr()?).await?;  in recv_buf()
536     sender.send(MSG).await?;  in recv_buf()
538     let len = receiver.recv_buf(&mut recv_buf).await?;  in recv_buf()
548     let server = UdpSocket::bind("127.0.0.1:0").await.unwrap();  in try_recv_buf_from()
552     let client = UdpSocket::bind("127.0.0.1:0").await.unwrap();  in try_recv_buf_from()
557             client.writable().await.unwrap();  in try_recv_buf_from()
570             server.readable().await.unwrap();  in try_recv_buf_from()
590     let sender = UdpSocket::bind("127.0.0.1:0").await?;  in recv_buf_from()
591     let receiver = UdpSocket::bind("127.0.0.1:0").await?;  in recv_buf_from()
593     sender.connect(receiver.local_addr()?).await?;  in recv_buf_from()
595     sender.send(MSG).await?;  in recv_buf_from()
597     let (len, caddr) = receiver.recv_buf_from(&mut recv_buf).await?;  in recv_buf_from()
608     let server = UdpSocket::bind("127.0.0.1:0").await.unwrap();  in poll_ready()
612     let client = UdpSocket::bind("127.0.0.1:0").await.unwrap();  in poll_ready()
617             assert_ok!(poll_fn(|cx| client.poll_send_ready(cx)).await);  in poll_ready()
630             assert_ok!(poll_fn(|cx| server.poll_recv_ready(cx)).await);  in poll_ready()