Add periodic ping broadcast for all subscribers

This will ensure the server can detect if a client has hung up without cleanly disconnecting
ff14wed · Mar 14, 2023 · 2a6c93f · 2a6c93f
1 parent 6791544
commit 2a6c93f
Show file tree

Hide file tree

Showing 2 changed files with 106 additions and 77 deletions.
diff --git a/src/lib.rs b/src/lib.rs
@@ -136,7 +136,7 @@ async fn main_with_result() -> Result<()> {
     // Block on server loop
     let hs_clone = hs.clone();
     if let Err(e) = deucalion_server
-        .run(pipe_name, move |payload: rpc::Payload| {
+        .run(pipe_name, true, move |payload: rpc::Payload| {
             handle_payload(payload, hs_clone.clone())
         })
         .await