Consume remaining chunks too

DaveCTurner · Nov 30, 2022 · 8c61355 · 8c61355
1 parent 0aac861
commit 8c61355
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/server/src/main/java/org/elasticsearch/rest/ChunkedRestResponseBody.java b/server/src/main/java/org/elasticsearch/rest/ChunkedRestResponseBody.java
@@ -117,6 +117,7 @@ public ReleasableBytesReference encodeChunk(int sizeHint, Recycler<BytesRef> rec
                         assert false : "failure encoding chunk";
                         IOUtils.closeWhileHandlingException(target);
                         target = null;
+                        serialization.forEachRemaining(ignored -> {});
                     }
                 }
             }