futures_api,
)]
-use std::{future::Future, pin::Pin, task::Poll};
+use std::{future::Future, pin::Pin, task::Poll, ptr};
+use std::task::{Waker, RawWaker, RawWakerVTable};
// See if we can run a basic `async fn`
pub async fn foo(x: &u32, y: u32) -> u32 {
*x + y + *a
}
-fn main() {
- use std::{sync::Arc, task::{Wake, local_waker}};
+fn raw_waker_clone(_this: *const ()) -> RawWaker {
+ panic!("unimplemented");
+}
+fn raw_waker_wake(_this: *const ()) {
+ panic!("unimplemented");
+}
+fn raw_waker_drop(_this: *const ()) {}
- struct NoWake;
- impl Wake for NoWake {
- fn wake(_arc_self: &Arc<Self>) {
- panic!();
- }
- }
+static RAW_WAKER: RawWakerVTable = RawWakerVTable {
+ clone: raw_waker_clone,
+ wake: raw_waker_wake,
+ drop: raw_waker_drop,
+};
- let lw = unsafe { local_waker(Arc::new(NoWake)) };
+fn main() {
let x = 5;
let mut fut = foo(&x, 7);
- assert_eq!(unsafe { Pin::new_unchecked(&mut fut) }.poll(&lw), Poll::Ready(31));
+ let waker = unsafe { Waker::new_unchecked(RawWaker::new(ptr::null(), &RAW_WAKER)) };
+ assert_eq!(unsafe { Pin::new_unchecked(&mut fut) }.poll(&waker), Poll::Ready(31));
}