minor clean up

AsyncHttpClient · Mar 28, 2017 · 9aec4b5 · 9aec4b5
1 parent 1e104ac
commit 9aec4b5
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 6 deletions.
diff --git a/client/src/main/java/org/asynchttpclient/DefaultAsyncHttpClient.java b/client/src/main/java/org/asynchttpclient/DefaultAsyncHttpClient.java
@@ -263,7 +263,7 @@ public ClientStats getClientStats() {
 
     @Override
     public void flushChannelPoolPartitions(Predicate<Object> predicate) {
-        channelManager.flushChannelPoolPartitions(predicate);
+        getChannelPool().flushPartitions(predicate);
     }
 
     protected BoundRequestBuilder requestBuilder(String method, String url) {

diff --git a/client/src/main/java/org/asynchttpclient/netty/channel/ChannelManager.java b/client/src/main/java/org/asynchttpclient/netty/channel/ChannelManager.java
@@ -49,7 +49,6 @@
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.TimeUnit;
 import java.util.function.Function;
-import java.util.function.Predicate;
 import java.util.stream.Collectors;
 
 import javax.net.ssl.SSLEngine;
@@ -522,8 +521,4 @@ public ClientStats getClientStats() {
                 ));
         return new ClientStats(statsPerHost);
     }
-
-    public void flushChannelPoolPartitions(Predicate<Object> predicate) {
-        channelPool.flushPartitions(predicate);
-    }
 }