Lines Matching refs:future
83 pub(crate) fn run<F>(future: F) -> (JoinHandle, impl Future<Output = Option<F::Output>>) in run()
93 let future = JoinHandleFuture { in run() localVariable
94 future: ManuallyDrop::new(future), in run()
97 (handle, future) in run()
127 future: ManuallyDrop<F>, field
141 let (state, future) = unsafe { in poll()
143 (&me.state, Pin::new_unchecked(&mut *me.future)) in poll()
163 future.poll(cx).map(Some) in poll()
176 ManuallyDrop::drop(&mut self.future); in drop()
205 fn is_ready<F>(future: Pin<&mut F>) -> bool in is_ready()
209 match future.poll(&mut Context::from_waker(Waker::noop())) { in is_ready()
218 let (mut handle, future) = JoinHandle::run(rx); in abort_in_progress()
221 let mut future = pin!(future); in abort_in_progress() localVariable
222 assert!(!is_ready(future.as_mut())); in abort_in_progress()
225 assert!(is_ready(future.as_mut())); in abort_in_progress()
236 let (mut handle, future) = JoinHandle::run(rx); in abort_complete()
241 let mut future = pin!(future); in abort_complete() localVariable
242 assert!(is_ready(future.as_mut())); in abort_complete()
253 let (mut handle, future) = JoinHandle::run(rx); in abort_dropped()
255 drop(future); in abort_dropped()
266 let (handle, future) = JoinHandle::run(rx); in await_completion()
267 let task = tokio::task::spawn(future); in await_completion()
276 let (handle, future) = JoinHandle::run(rx); in await_abort()
278 let task = tokio::task::spawn(future); in await_abort()