fix(runtime): accept Instance in create_timer

compio-runtime/src/runtime/mod.rs

@@ -287,12 +287,8 @@ impl Runtime {
     }
 
     #[cfg(feature = "time")]
-    pub(crate) fn create_timer(&self, delay: std::time::Duration) -> impl Future<Output = ()> {
-        if delay.is_zero() {
-            Either::Right(std::future::ready(()))
-        } else {
-            Either::Left(TimerFuture::new(std::time::Instant::now() + delay))
-        }
+    pub(crate) fn create_timer(&self, instant: std::time::Instant) -> impl Future<Output = ()> {
+        TimerFuture::new(instant)
     }
 
     pub(crate) fn cancel_op<T: OpCode>(&self, op: Key<T>) {

compio-runtime/src/runtime/time.rs

@@ -73,7 +73,7 @@ impl TimerRuntime {
 
     pub fn insert(&mut self, instant: Instant) -> Option<usize> {
         let delay = instant - self.time;
-        if delay.is_zero() {
+        if delay <= self.time.elapsed() {
             return None;
         }
         let key = self.tasks.insert(FutureState::Active(None));

compio-runtime/src/time.rs

@@ -33,7 +33,7 @@ use crate::Runtime;
 /// # })
 /// ```
 pub async fn sleep(duration: Duration) {
-    Runtime::with_current(|r| r.create_timer(duration)).await
+    sleep_until(Instant::now() + duration).await
 }
 
 /// Waits until `deadline` is reached.
@@ -55,7 +55,7 @@ pub async fn sleep(duration: Duration) {
 /// # })
 /// ```
 pub async fn sleep_until(deadline: Instant) {
-    sleep(deadline - Instant::now()).await
+    Runtime::with_current(|r| r.create_timer(deadline)).await
 }
 
 /// Error returned by [`timeout`] or [`timeout_at`].