Skip to content

Commit 28b0283

Browse files
shorter
1 parent deffad7 commit 28b0283

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

server/src/main/java/org/elasticsearch/transport/InboundDecoder.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -113,10 +113,8 @@ public int internalDecode(ReleasableBytesReference reference, CheckedConsumer<Ob
113113
bytesConsumed += bytesConsumedThisDecode;
114114
ReleasableBytesReference decompressed;
115115
while ((decompressed = decompressor.pollDecompressedPage(isDone())) != null) {
116-
try {
117-
fragmentConsumer.accept(decompressed);
118-
} finally {
119-
decompressed.close();
116+
try (var buf = decompressed) {
117+
fragmentConsumer.accept(buf);
120118
}
121119
}
122120
} else {

0 commit comments

Comments
 (0)