Send end of stream properly

rtimush · rtimush · commit 3f0ca2fb0cef · 2016-02-24T15:04:17.000+03:00
diff --git a/src/main/java/com/github/dockerjava/netty/InvocationBuilder.java b/src/main/java/com/github/dockerjava/netty/InvocationBuilder.java
@@ -4,6 +4,8 @@
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelFuture;
 import io.netty.channel.ChannelFutureListener;
+import io.netty.channel.socket.DuplexChannel;
+import io.netty.channel.socket.SocketChannel;
 import io.netty.handler.codec.http.DefaultFullHttpRequest;
 import io.netty.handler.codec.http.DefaultHttpRequest;
 import io.netty.handler.codec.http.FullHttpRequest;
@@ -262,6 +264,12 @@ public void run() {
                         channel.writeAndFlush(Unpooled.copiedBuffer(buffer, 0, read));
                     }
 
+                    // we close the writing side of the socket, but keep the read side open to transfer stdout/stderr
+                    // unfortunately, shutdownOutput is not supported by io.netty.channel.epoll.EpollDomainSocketChannel
+                    if (channel instanceof DuplexChannel) {
+                        ((DuplexChannel) channel).shutdownOutput();
+                    }
+
                 }
             }).start();
         }
