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