Searched refs:poll_write_ready (Results 1 – 7 of 7) sorted by relevance
53 poll_fn(|cx| stream.io.registration().poll_write_ready(cx)).await?; in connect()430 pub fn poll_write_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_write_ready() method431 self.io.registration().poll_write_ready(cx).map_ok(|_| ()) in poll_write_ready()
152 assert_ok!(poll_fn(|cx| $stream.poll_write_ready(cx)).await);159 assert_pending!($stream.poll_write_ready(cx));190 async fn poll_write_ready() { in poll_write_ready() function
177 assert_ok!(poll_fn(|cx| $stream.poll_write_ready(cx)).await);184 assert_pending!($stream.poll_write_ready(cx));215 async fn poll_write_ready() { in poll_write_ready() function
433 .poll_write_ready(cx)))); in poll_fns()436 let _ = futures::future::poll_fn(|cx| afd_a_2.as_ref().poll_write_ready(cx)).await; in poll_fns()551 futures::future::poll_fn(|cx| fd.poll_write_ready(cx)).await in poll_writable()
341 pub fn poll_write_ready<'a>( in poll_write_ready() method345 let event = ready!(self.registration.poll_write_ready(cx))?; in poll_write_ready()383 let event = ready!(self.registration.poll_write_ready(cx))?; in poll_write_ready_mut()
146 poll_fn(|cx| stream.io.registration().poll_write_ready(cx)).await?; in connect_mio()718 pub fn poll_write_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_write_ready() method719 self.io.registration().poll_write_ready(cx).map_ok(|_| ()) in poll_write_ready()
122 pub(crate) fn poll_write_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<ReadyEvent>> { in poll_write_ready() method