• Home
  • Raw
  • Download

Lines Matching refs:readable

181         _ = afd_a.readable().fuse() => panic!("Unexpected readable state"),  in initially_writable()
182 _ = afd_b.readable().fuse() => panic!("Unexpected readable state"), in initially_writable()
192 let readable = afd_a.readable(); in reset_readable() localVariable
193 tokio::pin!(readable); in reset_readable()
196 _ = readable.as_mut() => panic!(), in reset_readable()
202 let mut guard = readable.await.unwrap(); in reset_readable()
211 afd_a.readable().await.unwrap().retain_ready(); in reset_readable()
216 let readable = afd_a.readable(); in reset_readable() localVariable
217 tokio::pin!(readable); in reset_readable()
220 _ = readable.as_mut() => panic!(), in reset_readable()
227 afd_a.readable().await.unwrap().clear_ready(); in reset_readable()
324 let mut guard = afd_a.readable().await.unwrap(); in try_io()
332 let _ = afd_a.readable().await.unwrap(); in try_io()
338 let readable = afd_a.readable(); in try_io() localVariable
339 tokio::pin!(readable); in try_io()
342 _ = readable.as_mut() => panic!(), in try_io()
348 let _ = readable.await.unwrap(); in try_io()
370 guard = afd_a.readable().fuse() => { in multiple_waiters()
442 let readable = afd_a.readable(); in poll_fns() localVariable
443 tokio::pin!(readable); in poll_fns()
446 _ = &mut readable => unreachable!(), in poll_fns()
453 let _ = tokio::join!(readable, read_fut); in poll_fns()
498 let readable = assert_pending(afd_a.readable()); in driver_shutdown_wakes_currently_pending() localVariable
503 assert_err!(futures::executor::block_on(readable)); in driver_shutdown_wakes_currently_pending()
506 assert_err!(futures::executor::block_on(afd_a.readable())); in driver_shutdown_wakes_currently_pending()
521 assert_err!(futures::executor::block_on(afd_a.readable())); in driver_shutdown_wakes_future_pending()
539 let _ = futures::executor::block_on(afd_a.readable()); in driver_shutdown_wakes_pending_race()
542 assert_err!(futures::executor::block_on(afd_a.readable())); in driver_shutdown_wakes_pending_race()
566 let readable = assert_pending(poll_readable(&afd_a)); in driver_shutdown_wakes_currently_pending_polls() localVariable
572 assert_err!(futures::executor::block_on(readable)); in driver_shutdown_wakes_currently_pending_polls()