missing channelPreempted flag update

slandelle · slandelle · commit c3902c6f8391 · 2015-04-02T19:32:34.000+02:00
diff --git a/providers/netty4/src/main/java/org/asynchttpclient/providers/netty4/request/NettyRequestSender.java b/providers/netty4/src/main/java/org/asynchttpclient/providers/netty4/request/NettyRequestSender.java
@@ -275,6 +275,7 @@ private <T> ListenableFuture<T> sendRequestWithNewChannel(//
                     partition = future.getPartitionId();
 
                 channelManager.preemptChannel(partition);
+                channelPreempted = true;
             }
 
             if (asyncHandler instanceof AsyncHandlerExtensions)

Original file line number	Diff line number	Diff line change
`@@ -275,6 +275,7 @@ private <T> ListenableFuture<T> sendRequestWithNewChannel(//`
`275`	`275`	`partition = future.getPartitionId();`
`276`	`276`
`277`	`277`	`channelManager.preemptChannel(partition);`
	`278`	`+ channelPreempted = true;`
`278`	`279`	`}`
`279`	`280`
`280`	`281`	`if (asyncHandler instanceof AsyncHandlerExtensions)`