Skip to content

Commit

Permalink
Fix previous commit
Browse files Browse the repository at this point in the history
  • Loading branch information
Stephane Landelle committed Nov 25, 2014
1 parent b4e9558 commit afd3068
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -323,8 +323,9 @@ public <T> void writeRequest(NettyResponseFuture<T> future, Channel channel) {
if (handler instanceof TransferCompletionHandler)
configureTransferAdapter(handler, httpRequest);

if (!future.isHeadersAlreadyWrittenOnContinue() &&future.getAsyncHandler() instanceof AsyncHandlerExtensions) {
AsyncHandlerExtensions.class.cast(future.getAsyncHandler()).onSendRequest(nettyRequest);
if (!future.isHeadersAlreadyWrittenOnContinue()) {
if (future.getAsyncHandler() instanceof AsyncHandlerExtensions)
AsyncHandlerExtensions.class.cast(future.getAsyncHandler()).onSendRequest(nettyRequest);
channel.write(httpRequest).addListener(new ProgressListener(config, future.getAsyncHandler(), future, true));
}

Expand Down

0 comments on commit afd3068

Please sign in to comment.