reactor AsyncPollable works with subscribe duration directly...

Author: pchickey

src/runtime/polling.rs

@@ -75,10 +75,10 @@ impl Poller {
         // to convert it back to the right keys for the wakers. Earlier we
         // established a positional index -> waker key relationship, so we can
         // go right ahead and perform a lookup there.
-        ready_indexes
+        dbg!(ready_indexes
             .into_iter()
             .map(|index| EventKey(indexes[index as usize] as u32))
-            .collect()
+            .collect())
     }
 }
 

src/runtime/reactor.rs

@@ -128,6 +128,7 @@ impl Reactor {
         for key in reactor.poller.block_until() {
             for (waitee, waker) in reactor.wakers.iter() {
                 if waitee.pollable.0.key == key {
+                    println!("waking {key:?}");
                     waker.wake_by_ref()
                 }
             }
@@ -175,3 +176,17 @@ impl Reactor {
         p.wait_for().await
     }
 }
+
+#[cfg(test)]
+mod test {
+    use super::*;
+    #[test]
+    fn reactor_subscribe_duration() {
+        crate::runtime::block_on(async {
+            let reactor = Reactor::current();
+            let pollable = wasi::clocks::monotonic_clock::subscribe_duration(1000);
+            let sched = reactor.schedule(pollable);
+            sched.wait_for().await;
+        })
+    }
+}