Allow Multipart with unknown content length, close AsyncHttpClient#427

Author: Stephane Landelle

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

@@ -475,10 +475,18 @@ protected final <T> void writeRequest(final Channel channel, final AsyncHttpClie
                     } else {
                         nettyRequest.setHeader(HttpHeaders.Names.TRANSFER_ENCODING, HttpHeaders.Values.CHUNKED);
                     }
-                    
+
                 } else if (future.getRequest().getParts() != null) {
                     String contentType = nettyRequest.getHeader(HttpHeaders.Names.CONTENT_TYPE);
-                    String length = nettyRequest.getHeader(HttpHeaders.Names.CONTENT_LENGTH);
+                    String contentLength = nettyRequest.getHeader(HttpHeaders.Names.CONTENT_LENGTH);
+
+                    long length = -1;
+                    if (contentLength != null) {
+                        length = Long.parseLong(contentLength);
+                    } else {
+                        nettyRequest.addHeader(HttpHeaders.Names.TRANSFER_ENCODING, HttpHeaders.Values.CHUNKED);
+                    }
+
                     body = new MultipartBody(future.getRequest().getParts(), contentType, length);
                 }
             }
@@ -822,7 +830,9 @@ else if (uri.getRawQuery() != null)
                     MultipartRequestEntity mre = AsyncHttpProviderUtils.createMultipartRequestEntity(request.getParts(), request.getHeaders());
 
                     nettyRequest.setHeader(HttpHeaders.Names.CONTENT_TYPE, mre.getContentType());
-                    nettyRequest.setHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(mre.getContentLength()));
+                    if (mre.getContentLength() >= 0) {
+                        nettyRequest.setHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(mre.getContentLength()));
+                    }
 
                 } else if (request.getEntityWriter() != null) {
                     int length = (int) request.getContentLength();

src/main/java/com/ning/http/multipart/MultipartBody.java

@@ -48,10 +48,9 @@ public class MultipartBody implements RandomAccessBody {
 
     enum FileLocation {NONE, START, MIDDLE, END}
 
-    public MultipartBody(List<com.ning.http.client.Part> parts, String contentType, String contentLength) {
+    public MultipartBody(List<com.ning.http.client.Part> parts, String contentType, Long contentLength) {
         this.boundary = MultipartEncodingUtil.getAsciiBytes(contentType.substring(contentType.indexOf("boundary=") + "boundary=".length()));
 
-        this.contentLength = Long.parseLong(contentLength);
         this.parts = parts;
 
         files = new ArrayList<RandomAccessFile>();