From ff0c9419f5371b3b3a5ba928631287f978711971 Mon Sep 17 00:00:00 2001
From: Jonathan Gamble <gamblej@gmail.com>
Date: Wed, 27 Nov 2024 07:57:16 -0600
Subject: [PATCH] report non-zero channelsToFlush

---
 src/main/scala/netty/ActorChannelConnector.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/scala/netty/ActorChannelConnector.scala b/src/main/scala/netty/ActorChannelConnector.scala
index e347a72b..08cda080 100644
--- a/src/main/scala/netty/ActorChannelConnector.scala
+++ b/src/main/scala/netty/ActorChannelConnector.scala
@@ -72,6 +72,7 @@ final private class ActorChannelConnector(
     val qSize           = flushQ.estimateSize()
     val maxDelayFactor  = config.interval.get().toDouble / config.maxDelay.get().atLeast(1)
     var channelsToFlush = config.step.get().atLeast((qSize * maxDelayFactor).toInt)
+    monitor.channelsToFlush.record(channelsToFlush)
 
     while channelsToFlush > 0 do
       flushQ.poll() match
@@ -82,7 +83,6 @@ final private class ActorChannelConnector(
           channelsToFlush = 0
 
     monitor.qSizeEstimate.record(qSize)
-    monitor.channelsToFlush.record(channelsToFlush)
     monitor.loopRuntimeMicroseconds.record((Deadline.now - entered).toMicros)
 
     entered + {