Lines Matching refs:poll_fn
4 use futures::future::poll_fn;
38 poll_fn(|cx| sender.poll_send(cx, MSG)).await?; in send_recv_poll()
42 poll_fn(|cx| receiver.poll_recv(cx, &mut read)).await?; in send_recv_poll()
70 poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?; in send_to_recv_from_poll()
74 let addr = poll_fn(|cx| receiver.poll_recv_from(cx, &mut read)).await?; in send_to_recv_from_poll()
87 poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?; in send_to_peek_from()
115 poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?; in send_to_peek_from_poll()
119 let addr = poll_fn(|cx| receiver.poll_peek_from(cx, &mut read)).await?; in send_to_peek_from_poll()
126 poll_fn(|cx| receiver.poll_peek_from(cx, &mut read)).await?; in send_to_peek_from_poll()
132 poll_fn(|cx| receiver.poll_recv_from(cx, &mut read)).await?; in send_to_peek_from_poll()
196 poll_fn(|cx| s.poll_send_to(cx, &bytes, addr)) in split_chan_poll()
206 let addr = poll_fn(|cx| r.poll_recv_from(cx, &mut read)).await.unwrap(); in split_chan_poll()
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()
457 assert_ok!(poll_fn(|cx| client.poll_send_ready(cx)).await); in poll_ready()
470 assert_ok!(poll_fn(|cx| server.poll_recv_ready(cx)).await); in poll_ready()