Fix clippy warning about queue size within listener loop

binaries/daemon/src/node_communication/mod.rs

@@ -184,7 +184,6 @@ struct Listener {
     subscribed_events: Option<UnboundedReceiver<Timestamped<NodeEvent>>>,
     subscribed_drop_events: Option<UnboundedReceiver<Timestamped<NodeDropEvent>>>,
     queue: VecDeque<Box<Option<Timestamped<NodeEvent>>>>,
-    queue_sizes: BTreeMap<DataId, usize>,
     clock: Arc<uhlc::HLC>,
 }
 
@@ -192,7 +191,6 @@ impl Listener {
     pub(crate) async fn run<C: Connection>(
         mut connection: C,
         daemon_tx: mpsc::Sender<Timestamped<Event>>,
-        queue_sizes: BTreeMap<DataId, usize>,
         hlc: Arc<uhlc::HLC>,
     ) {
         // receive the first message
@@ -233,7 +231,6 @@ impl Listener {
                             daemon_tx,
                             subscribed_events: None,
                             subscribed_drop_events: None,
-                            queue_sizes,
                             queue: VecDeque::new(),
                             clock: hlc.clone(),
                         };

binaries/daemon/src/node_communication/shmem.rs

@@ -39,7 +39,7 @@ pub async fn listener_loop(
         }
     });
     let connection = ShmemConnection(tx);
-    Listener::run(connection, daemon_tx, queue_sizes, clock).await
+    Listener::run(connection, daemon_tx, clock).await
 }
 
 enum Operation {

binaries/daemon/src/node_communication/tcp.rs

@@ -54,7 +54,7 @@ async fn handle_connection_loop(
         tracing::warn!("failed to set nodelay for connection: {err}");
     }
 
-    Listener::run(TcpConnection(connection), daemon_tx, queue_sizes, clock).await
+    Listener::run(TcpConnection(connection), daemon_tx, clock).await
 }
 
 struct TcpConnection(TcpStream);

binaries/daemon/src/node_communication/unix_domain.rs

@@ -52,7 +52,7 @@ async fn handle_connection_loop(
     queue_sizes: BTreeMap<DataId, usize>,
     clock: Arc<HLC>,
 ) {
-    Listener::run(UnixConnection(connection), daemon_tx, queue_sizes, clock).await
+    Listener::run(UnixConnection(connection), daemon_tx, clock).await
 }
 
 struct UnixConnection(UnixStream);