more complete rekey timer

still todo: reject-after timeouts

1 files changed, 5 insertions, 0 deletions

diff --git a/src/timer.rs b/src/timer.rs
index a2f3833..ed5168c 100644
--- a/src/timer.rs
+++ b/src/timer.rs
@@ -25,6 +25,7 @@ impl Timer {
     }
 
     pub fn spawn_delayed(&mut self, handle: &Handle, delay: Duration, message: TimerMessage) {
+        trace!("queuing timer message {:?}", &message);
         let timer = self.timer.sleep(delay);
         let future = timer.and_then({
             let tx = self.tx.clone();
@@ -34,6 +35,10 @@ impl Timer {
         }).then(|_| Ok(()));
         handle.spawn(future);
     }
+
+    pub fn spawn_immediately(&mut self, handle: &Handle, message: TimerMessage) {
+       handle.spawn(self.tx.clone().send(message).then(|_| Ok(())));
+    }
 }
 
 impl Stream for Timer {