From 3776d7bb4cf67bf83b4bc500363fece72de75848 Mon Sep 17 00:00:00 2001 From: Bastian Gruber Date: Sun, 21 May 2023 14:43:52 +0200 Subject: [PATCH] Fix hearbeat --- problem_06/src/server.rs | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/problem_06/src/server.rs b/problem_06/src/server.rs index 21e8e34..f69304e 100644 --- a/problem_06/src/server.rs +++ b/problem_06/src/server.rs @@ -179,6 +179,7 @@ impl Handler { frame: ClientFrames, send_message: mpsc::Sender, ) -> crate::Result<()> { + debug!(?frame); match frame { ClientFrames::Plate { plate, timestamp } => { info!("Receive new plate {plate} {timestamp}"); @@ -201,10 +202,12 @@ impl Handler { .await; } ClientFrames::WantHeartbeat { interval } => { - tokio::spawn(async move { - let mut heartbeat = Heartbeat::new(interval, send_message.clone()); - heartbeat.start().await; - }); + if interval > 0 { + tokio::spawn(async move { + let mut heartbeat = Heartbeat::new(interval, send_message.clone()); + heartbeat.start().await; + }); + } } ClientFrames::IAmCamera { road, mile, limit } => { if self.connection_type.is_some() {