Fix Interval usage

whisperfish · Jan 8, 2021 · 7edb1eb · 7edb1eb
1 parent 8e275d9
commit 7edb1eb
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/libsignal-service-actix/src/websocket.rs b/libsignal-service-actix/src/websocket.rs
@@ -67,12 +67,13 @@ where
     let mut ka_interval = actix::clock::interval_at(
         actix::clock::Instant::now(),
         push_service::KEEPALIVE_TIMEOUT_SECONDS,
-    )
-    .fuse();
+    );
 
     loop {
+        let mut tick = ka_interval.tick().fuse();
+        futures::pin_mut!(tick);
         futures::select! {
-            _ = ka_interval.next() => {
+            _ = tick => {
                 log::trace!("Triggering keep-alive");
                 if let Err(e) = incoming_sink.send(WebSocketStreamItem::KeepAliveRequest).await {
                     log::info!("Websocket sink has closed: {:?}.", e);