From 240bb218d0e2336cc7816e2366af5d7bc17270f0 Mon Sep 17 00:00:00 2001
From: "Franz Heinzmann (Frando)" <frando@unbiskant.org>
Date: Thu, 16 May 2024 12:23:08 +0200
Subject: [PATCH] address review comments

---
 iroh/src/docs_engine/gossip.rs | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git a/iroh/src/docs_engine/gossip.rs b/iroh/src/docs_engine/gossip.rs
index b9b6cea476..373bd20ec6 100644
--- a/iroh/src/docs_engine/gossip.rs
+++ b/iroh/src/docs_engine/gossip.rs
@@ -2,11 +2,9 @@ use std::collections::HashSet;
 
 use anyhow::{Context, Result};
 use futures_lite::StreamExt;
+use futures_util::FutureExt;
 use iroh_docs::{actor::SyncHandle, ContentStatus, NamespaceId};
-use iroh_gossip::{
-    net::{Event, Gossip},
-    proto::TopicId,
-};
+use iroh_gossip::net::{Event, Gossip};
 use iroh_net::key::PublicKey;
 use tokio::{
     sync::{broadcast, mpsc},
@@ -16,7 +14,7 @@ use tokio_stream::{
     wrappers::{errors::BroadcastStreamRecvError, BroadcastStream},
     StreamMap,
 };
-use tracing::{debug, error, trace};
+use tracing::{debug, error, trace, warn};
 
 use super::live::{Op, ToLiveActor};
 
@@ -64,7 +62,6 @@ impl GossipActor {
         }
     }
     pub async fn run(&mut self) -> anyhow::Result<()> {
-        // let mut gossip_events = self.gossip.clone().subscribe_all();
         let mut i = 0;
         loop {
             i += 1;
@@ -144,7 +141,7 @@ impl GossipActor {
         let event = match event {
             Ok(event) => event,
             Err(BroadcastStreamRecvError::Lagged(n)) => {
-                error!("GossipActor too slow (lagged by {n}) - dropping gossip event");
+                warn!("GossipActor too slow (lagged by {n}) - dropping gossip event");
                 return Ok(());
             }
         };