Skip to content

Commit 485a553

Browse files
committed
last empty chunk release
1 parent 1137b22 commit 485a553

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

server/src/main/java/org/elasticsearch/rest/RestContentAggregator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -167,12 +167,12 @@ static class NoContent implements ChunkHandler {
167167

168168
@Override
169169
public void onNext(final ReleasableBytesReference lastEmptyChunk, boolean isLast) throws Exception {
170-
lastEmptyChunk.close();
171170
if (lastEmptyChunk.length() == 0 && isLast) {
172171
var aggReq = new RestRequest(request, new AggregatedHttpRequest(request.getHttpRequest(), HttpBody.empty()));
173172
var aggChan = new AggregatedRestRequestChannel(channel, aggReq);
174173
result.accept(aggReq, aggChan);
175174
} else {
175+
lastEmptyChunk.close();
176176
request.contentStream().close();
177177
channel.sendResponse(new RestResponse(RestStatus.BAD_REQUEST, "unexpected HTTP content"));
178178
}

0 commit comments

Comments
 (0)