feedback

Consensys · Nov 22, 2024 · b73c975 · b73c975
1 parent 439e2a8
commit b73c975
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/.../src/main/java/tech/pegasys/teku/networking/eth2/rpc/core/Eth2OutgoingRequestHandler.java b/.../src/main/java/tech/pegasys/teku/networking/eth2/rpc/core/Eth2OutgoingRequestHandler.java
@@ -110,10 +110,9 @@ public void processData(final NodeId nodeId, final RpcStream rpcStream, final By
       for (TResponse maybeResponse : maybeResponses) {
         getResponseProcessor(rpcStream).processResponse(maybeResponse);
       }
-      if (chunksReceived == maximumResponseChunks) {
-        if (!transferToState(DATA_COMPLETED, List.of(EXPECT_DATA))) {
-          abortRequest(rpcStream, new IllegalStateException("Unexpected state: " + state));
-        }
+      if (chunksReceived >= maximumResponseChunks
+          && !transferToState(DATA_COMPLETED, List.of(EXPECT_DATA))) {
+        abortRequest(rpcStream, new IllegalStateException("Unexpected state: " + state));
       }
     } catch (final RpcException e) {
       abortRequest(rpcStream, e);