From cb658ca4819368561ca4b886dfed0faa4e67bac0 Mon Sep 17 00:00:00 2001
From: Federico Gimenez <federico.gimenez@gmail.com>
Date: Tue, 21 May 2024 10:24:55 +0200
Subject: [PATCH] do not handle broadcast send Ok result with 0 listeners

---
 crates/tokio-util/src/event_listeners.rs | 13 ++++---------
 1 file changed, 4 insertions(+), 9 deletions(-)

diff --git a/crates/tokio-util/src/event_listeners.rs b/crates/tokio-util/src/event_listeners.rs
index 36992460ceeb..39138bf15a55 100644
--- a/crates/tokio-util/src/event_listeners.rs
+++ b/crates/tokio-util/src/event_listeners.rs
@@ -1,6 +1,6 @@
 use tokio::sync::broadcast::{self, Sender};
 use tokio_stream::wrappers::BroadcastStream;
-use tracing::{error, warn};
+use tracing::error;
 
 const DEFAULT_SIZE_BROADCAST_CHANNEL: usize = 1000;
 
@@ -26,14 +26,9 @@ impl<T: Clone + Send + Sync + 'static> EventListeners<T> {
 
     /// Broadcasts an event to all listeners.
     pub fn notify(&self, event: T) {
-        match self.sender.send(event) {
-            Ok(listener_count) => {
-                if listener_count == 0 {
-                    warn!("notification of network event with 0 listeners");
-                }
-            }
-            Err(_) => error!("channel closed"),
-        };
+        if self.sender.send(event).is_err() {
+            error!("channel closed");
+        }
     }
 
     /// Adds a new event listener and returns the associated receiver.