Searched refs:poll_read_ready (Results 1 – 9 of 9) sorted by relevance
136 assert_ok!(poll_fn(|cx| $stream.poll_read_ready(cx)).await);143 assert_pending!($stream.poll_read_ready(cx));167 async fn poll_read_ready() { in poll_read_ready() function
161 assert_ok!(poll_fn(|cx| $stream.poll_read_ready(cx)).await);168 assert_pending!($stream.poll_read_ready(cx));192 async fn poll_read_ready() { in poll_read_ready() function
409 assert_pending!(afd_a.as_ref().poll_read_ready(&mut waker.context())); in poll_fns()419 .poll_read_ready(cx)))); in poll_fns()422 let _ = futures::future::poll_fn(|cx| afd_a_2.as_ref().poll_read_ready(cx)).await; in poll_fns()547 futures::future::poll_fn(|cx| fd.poll_read_ready(cx)).await in poll_readable()
263 pub fn poll_read_ready<'a>( in poll_read_ready() method267 let event = ready!(self.registration.poll_read_ready(cx))?; in poll_read_ready()305 let event = ready!(self.registration.poll_read_ready(cx))?; in poll_read_ready_mut()
333 let ev = ready!(self.io.registration().poll_read_ready(cx))?; in poll_peek()495 pub fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_read_ready() method496 self.io.registration().poll_read_ready(cx).map_ok(|_| ()) in poll_read_ready()
168 let ev = ready!(self.io.registration().poll_read_ready(cx))?; in poll_accept()
203 pub fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_read_ready() method204 self.io.registration().poll_read_ready(cx).map_ok(|_| ()) in poll_read_ready()
106 let ev = match self.receiver.registration().poll_read_ready(&mut cx) { in process()
116 pub(crate) fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<ReadyEvent>> { in poll_read_ready() method