We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a70031f commit 2a8e147Copy full SHA for 2a8e147
client/src/main/java/org/asynchttpclient/netty/request/body/BodyChunkedInput.java
@@ -15,6 +15,7 @@
15
16
import static org.asynchttpclient.util.Assertions.assertNotNull;
17
import io.netty.buffer.ByteBuf;
18
+import io.netty.buffer.ByteBufAllocator;
19
import io.netty.channel.ChannelHandlerContext;
20
import io.netty.handler.stream.ChunkedInput;
21
@@ -47,7 +48,7 @@ public ByteBuf readChunk(ChannelHandlerContext ctx) throws Exception {
47
48
if (endOfInput)
49
return null;
50
- ByteBuf buffer = ctx.alloc().buffer(chunkSize);
51
+ ByteBuf buffer = ByteBufAllocator.DEFAULT.buffer(chunkSize);
52
Body.BodyState state = body.transferTo(buffer);
53
switch (state) {
54
case STOP:
0 commit comments