File tree Expand file tree Collapse file tree 1 file changed +7
-8
lines changed
client/src/main/java/org/asynchttpclient/netty/request/body Expand file tree Collapse file tree 1 file changed +7
-8
lines changed Original file line number Diff line number Diff line change 15
15
16
16
import static org .asynchttpclient .util .MiscUtils .closeSilently ;
17
17
import io .netty .channel .Channel ;
18
- import io .netty .channel .ChannelFuture ;
19
18
import io .netty .channel .ChannelProgressiveFuture ;
20
19
import io .netty .handler .codec .http .LastHttpContent ;
21
20
import io .netty .handler .stream .ChunkedWriteHandler ;
@@ -83,13 +82,13 @@ public void onError(Throwable t) {
83
82
}
84
83
}
85
84
86
- ChannelFuture writeFuture = channel .write (msg , channel .newProgressivePromise ());
87
- writeFuture .addListener (new WriteProgressListener (future , false , getContentLength ()) {
88
- public void operationComplete (ChannelProgressiveFuture cf ) {
89
- closeSilently (body );
90
- super .operationComplete (cf );
91
- }
92
- });
85
+ channel .write (msg , channel .newProgressivePromise ())//
86
+ .addListener (new WriteProgressListener (future , false , getContentLength ()) {
87
+ public void operationComplete (ChannelProgressiveFuture cf ) {
88
+ closeSilently (body );
89
+ super .operationComplete (cf );
90
+ }
91
+ });
93
92
channel .writeAndFlush (LastHttpContent .EMPTY_LAST_CONTENT , channel .voidPromise ());
94
93
}
95
94
}
You can’t perform that action at this time.
0 commit comments