InputStream shouldn't be fully read, this is streaming! close AsyncHttpClient#576

Author: Stephane Landelle

src/main/java/com/ning/http/client/providers/netty/NettyAsyncHttpProvider.java

@@ -487,6 +487,11 @@ protected final <T> void writeRequest(final Channel channel, final AsyncHttpClie
             Body body = null;
             if (!nettyRequest.getMethod().equals(HttpMethod.CONNECT)) {
                 BodyGenerator bg = future.getRequest().getBodyGenerator();
+
+                if (bg == null && future.getRequest().getStreamData() != null) {
+                    bg = new InputStreamBodyGenerator(future.getRequest().getStreamData());
+                }
+
                 if (bg != null) {
                     // Netty issue with chunking.
                     if (bg instanceof InputStreamBodyGenerator) {
@@ -834,12 +839,6 @@ else if (uri.getRawQuery() != null)
                 byte[] bytes = request.getStringData().getBytes(bodyCharset);
                 nettyRequest.setHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(bytes.length));
                 nettyRequest.setContent(ChannelBuffers.wrappedBuffer(bytes));
-            } else if (request.getStreamData() != null) {
-                int[] lengthWrapper = new int[1];
-                byte[] bytes = AsyncHttpProviderUtils.readFully(request.getStreamData(), lengthWrapper);
-                int length = lengthWrapper[0];
-                nettyRequest.setHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(length));
-                nettyRequest.setContent(ChannelBuffers.wrappedBuffer(bytes, 0, length));
             } else if (isNonEmpty(request.getParams())) {
                 StringBuilder sb = new StringBuilder();
                 for (final Entry<String, List<String>> paramEntry : request.getParams()) {