Blob Blame History Raw
From cfc7a97f2ed55bdfea4a54f510ea17039b259644 Mon Sep 17 00:00:00 2001
From: Tomas Repik <trepik@redhat.com>
Date: Mon, 3 Jul 2017 18:47:19 +0200
Subject: [PATCH] Netty update workaround (commit 454cbfe)

---
 driver-core/src/main/com/mongodb/connection/netty/NettyStream.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/driver-core/src/main/com/mongodb/connection/netty/NettyStream.java b/driver-core/src/main/com/mongodb/connection/netty/NettyStream.java
index 8ef8713..eae9db0 100644
--- a/driver-core/src/main/com/mongodb/connection/netty/NettyStream.java
+++ b/driver-core/src/main/com/mongodb/connection/netty/NettyStream.java
@@ -177,7 +177,8 @@ final class NettyStream implements Stream {
     public void writeAsync(final List<ByteBuf> buffers, final AsyncCompletionHandler<Void> handler) {
         CompositeByteBuf composite = PooledByteBufAllocator.DEFAULT.compositeBuffer();
         for (ByteBuf cur : buffers) {
-            composite.addComponent(true, ((NettyByteBuf) cur).asByteBuf());
+            composite.addComponent(((NettyByteBuf) cur).asByteBuf());
+            composite.writerIndex(composite.writerIndex() + ((NettyByteBuf) cur).asByteBuf().readableBytes());
         }
 
         channel.writeAndFlush(composite).addListener(new ChannelFutureListener() {
-- 
2.9.4