diff --git a/client/src/main/java/org/asynchttpclient/netty/channel/DefaultChannelPool.java b/client/src/main/java/org/asynchttpclient/netty/channel/DefaultChannelPool.java index f59d427f9..7811f16bd 100755 --- a/client/src/main/java/org/asynchttpclient/netty/channel/DefaultChannelPool.java +++ b/client/src/main/java/org/asynchttpclient/netty/channel/DefaultChannelPool.java @@ -362,6 +362,10 @@ public void run(Timeout timeout) { totalCount += partition.size(); } + if (partition.isEmpty()) { + continue; + } + closedCount += reapPartition(partition, start); }