Decode network unconditionally when received window on session stream (…

…#1386)
aklivity · Jan 29, 2025 · 620bfde · 620bfde
1 parent 756edc0
commit 620bfde
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/...c/main/java/io/aklivity/zilla/runtime/binding/mqtt/internal/stream/MqttServerFactory.java b/...c/main/java/io/aklivity/zilla/runtime/binding/mqtt/internal/stream/MqttServerFactory.java
@@ -5174,10 +5174,7 @@ private void onSessionWindow(
 
                 assert initialAck <= initialSeq;
 
-                if (!wasOpen || willPayloadBytes != 0)
-                {
-                    decodeNetwork(traceId);
-                }
+                decodeNetwork(traceId);
 
                 if (budgetId != 0L && debitorIndex == NO_DEBITOR_INDEX)
                 {