From 874f7c26e550a71e7ed49fdd897afeee102155c1 Mon Sep 17 00:00:00 2001
From: Bastian Gruber <foreach@me.com>
Date: Sun, 14 May 2023 20:42:49 +0200
Subject: [PATCH] Add gossip to join

---
 03b-multi-node-broadcast/src/main.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/03b-multi-node-broadcast/src/main.rs b/03b-multi-node-broadcast/src/main.rs
index 811a63d..92605b3 100644
--- a/03b-multi-node-broadcast/src/main.rs
+++ b/03b-multi-node-broadcast/src/main.rs
@@ -36,7 +36,7 @@ async fn main() {
         write_to_stdout(&mut writer_rx).await;
     });
 
-    tokio::spawn(async move {
+    let gossip = tokio::spawn(async move {
         loop {
             interval.tick().await;
             gossip_messages(n1.clone(), writer_tx2.clone()).await;
@@ -47,7 +47,7 @@ async fn main() {
         handle_messages(n2, &mut reader_rx, writer_tx1).await;
     });
 
-    let _ = tokio::try_join!(read, handle, write);
+    let _ = tokio::try_join!(read, handle, write, gossip);
 }
 
 async fn read_from_stdin(reader_tx: Sender<Message>) {