File tree Expand file tree Collapse file tree 2 files changed +1
-6
lines changed
client/src/main/java/org/asynchttpclient Expand file tree Collapse file tree 2 files changed +1
-6
lines changed Original file line number Diff line number Diff line change @@ -263,7 +263,7 @@ public ClientStats getClientStats() {
263
263
264
264
@ Override
265
265
public void flushChannelPoolPartitions (Predicate <Object > predicate ) {
266
- channelManager . flushChannelPoolPartitions (predicate );
266
+ getChannelPool (). flushPartitions (predicate );
267
267
}
268
268
269
269
protected BoundRequestBuilder requestBuilder (String method , String url ) {
Original file line number Diff line number Diff line change 49
49
import java .util .concurrent .ThreadFactory ;
50
50
import java .util .concurrent .TimeUnit ;
51
51
import java .util .function .Function ;
52
- import java .util .function .Predicate ;
53
52
import java .util .stream .Collectors ;
54
53
55
54
import javax .net .ssl .SSLEngine ;
@@ -522,8 +521,4 @@ public ClientStats getClientStats() {
522
521
));
523
522
return new ClientStats (statsPerHost );
524
523
}
525
-
526
- public void flushChannelPoolPartitions (Predicate <Object > predicate ) {
527
- channelPool .flushPartitions (predicate );
528
- }
529
524
}
You can’t perform that action at this time.
0 commit comments