diff --git a/client/src/main/java/org/asynchttpclient/DefaultAsyncHttpClient.java b/client/src/main/java/org/asynchttpclient/DefaultAsyncHttpClient.java
index 104e0ed75d..ebb34d1461 100644
--- 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
index 7582153e8d..532d70dc5d 100755
--- 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);
-    }
 }