@@ -400,34 +400,25 @@ protected final <T> void writeRequest(final Channel channel,
400
400
401
401
if (future .getAndSetWriteBody (true )) {
402
402
if (!future .getNettyRequest ().getMethod ().equals (HttpMethod .CONNECT )) {
403
- if (future .getRequest ().getParts () != null ) {
404
- String boundary = future .getNettyRequest ().getHeader (
405
- "Content-Type" );
406
-
407
- String length = future .getNettyRequest ().getHeader (
408
- "Content-Length" );
409
-
410
- final MultipartBody multipartBody = new MultipartBody (
411
- future .getRequest ().getParts (), boundary , length );
412
-
413
- ChannelFuture writeFuture = channel .write (
414
- new BodyFileRegion (multipartBody ));
415
-
416
- final Body b = multipartBody ;
417
-
418
- writeFuture .addListener (new ProgressListener (
419
- false , future .getAsyncHandler (), future ) {
403
+ if (future .getRequest ().getParts () != null ) {
404
+ String boundary = future .getNettyRequest ().getHeader ("Content-Type" );
405
+ String length = future .getNettyRequest ().getHeader ("Content-Length" );
406
+ final MultipartBody multipartBody = new MultipartBody (future .getRequest ().getParts (), boundary , length );
407
+ ChannelFuture writeFuture = channel .write (new BodyFileRegion (multipartBody ));
408
+
409
+ writeFuture .addListener (new ProgressListener (false , future .getAsyncHandler (), future ) {
410
+
420
411
public void operationComplete (ChannelFuture cf ) {
421
412
try {
422
- b .close ();
413
+ multipartBody .close ();
423
414
} catch (IOException e ) {
424
415
log .warn ("Failed to close request body: {}" , e .getMessage (), e );
425
416
}
426
417
super .operationComplete (cf );
427
418
}
419
+
428
420
});
429
- }
430
- else if (future .getRequest ().getFile () != null ) {
421
+ } else if (future .getRequest ().getFile () != null ) {
431
422
final File file = future .getRequest ().getFile ();
432
423
long fileLength = 0 ;
433
424
final RandomAccessFile raf = new RandomAccessFile (file , "r" );
0 commit comments