Merge pull request #542 from docker-java/issue-531

marcuslinke · marcuslinke · commit 854636e1c74d · 2016-04-08T20:37:08.000+02:00
Fix issue #531
diff --git a/src/main/java/com/github/dockerjava/netty/handler/FramedResponseStreamHandler.java b/src/main/java/com/github/dockerjava/netty/handler/FramedResponseStreamHandler.java
@@ -62,6 +62,7 @@ protected void channelRead0(ChannelHandlerContext ctx, ByteBuf msg) throws Excep
     private int read(byte[] buf, int offset, int length) {
         length = Math.min(rawBuffer.readableBytes(), length);
         rawBuffer.readBytes(buf, offset, length);
+        rawBuffer.discardReadBytes();
         return length;
     }
 

Original file line number	Diff line number	Diff line change
`@@ -62,6 +62,7 @@ protected void channelRead0(ChannelHandlerContext ctx, ByteBuf msg) throws Excep`
`62`	`62`	`private int read(byte[] buf, int offset, int length) {`
`63`	`63`	`length = Math.min(rawBuffer.readableBytes(), length);`
`64`	`64`	`rawBuffer.readBytes(buf, offset, length);`
	`65`	`+ rawBuffer.discardReadBytes();`
`65`	`66`	`return length;`
`66`	`67`	`}`
`67`	`68`