Merge pull request #380 from nervosnetwork/change-interval-init-behavior

chore: bump to 0.6.4

Author: driftluo

CHANGELOG.md

@@ -1,3 +1,8 @@
+## tentacle 0.6.4
+
+## Feature
+- Make `runtime::Interval` behavior same as tokio interval(#379)
+
 ## tentacle 0.6.3
 
 ## Bug Fix

tentacle/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "tentacle"
-version = "0.6.3"
+version = "0.6.4"
 license = "MIT"
 description = "Minimal implementation for a multiplexed p2p network framework."
 authors = ["piaoliu <driftluo@foxmail.com>", "Nervos Core Dev <dev@nervos.org>"]

tentacle/src/runtime/generic_timer.rs

@@ -14,9 +14,15 @@ pub struct Interval {
 }
 
 impl Interval {
+    /// Same as tokio::time::interval
     pub fn new(period: Duration) -> Self {
+        Self::new_at(Duration::ZERO, period)
+    }
+
+    /// Same as tokio::time::interval_at
+    pub fn new_at(start_since_now: Duration, period: Duration) -> Self {
         Self {
-            delay: Delay::new(period),
+            delay: Delay::new(start_since_now),
             period,
         }
     }

tentacle/src/runtime/tokio_runtime.rs

@@ -33,8 +33,14 @@ mod time {
     pub struct Interval(Inner);
 
     impl Interval {
+        /// Same as tokio::time::interval
         pub fn new(period: Duration) -> Self {
-            Self(inner_interval(Instant::now() + period, period))
+            Self::new_at(Duration::ZERO, period)
+        }
+
+        /// Same as tokio::time::interval_at
+        pub fn new_at(start_since_now: Duration, period: Duration) -> Self {
+            Self(inner_interval(Instant::now() + start_since_now, period))
         }
 
         pub fn set_missed_tick_behavior(&mut self, behavior: MissedTickBehavior) {