Rename ReaperFuture into FutureReaper

Author: Stephane Landelle

providers/netty4/src/main/java/org/asynchttpclient/providers/netty4/ReaperFuture.java renamed to providers/netty4/src/main/java/org/asynchttpclient/providers/netty4/FutureReaper.java

@@ -14,15 +14,15 @@
  * Because some implementation of the ThreadSchedulingService do not clean up cancel task until they try to run them, we wrap the task with the future so the when the NettyResponseFuture cancel the reaper future this wrapper will release the references to the channel and the
  * nettyResponseFuture immediately. Otherwise, the memory referenced this way will only be released after the request timeout period which can be arbitrary long.
  */
-public final class ReaperFuture implements Runnable {
+public final class FutureReaper implements Runnable {
 
     private final AtomicBoolean isClose;
     private final Channels channels;
     private Future<?> scheduledFuture;
     private NettyResponseFuture<?> nettyResponseFuture;
     private AsyncHttpClientConfig config;
 
-    public ReaperFuture(NettyResponseFuture<?> nettyResponseFuture, AsyncHttpClientConfig config, AtomicBoolean isClose, Channels channels) {
+    public FutureReaper(NettyResponseFuture<?> nettyResponseFuture, AsyncHttpClientConfig config, AtomicBoolean isClose, Channels channels) {
         this.nettyResponseFuture = nettyResponseFuture;
         this.channels = channels;
         this.config = config;

providers/netty4/src/main/java/org/asynchttpclient/providers/netty4/NettyRequestSender.java

@@ -403,7 +403,7 @@ private void scheduleReaper(NettyResponseFuture<?> future) {
                     : requestTimeout) : config.getIdleConnectionTimeoutInMs();
 
             if (schedulePeriod != -1 && !future.isDone() && !future.isCancelled()) {
-                ReaperFuture reaperFuture = new ReaperFuture(future, config, isClose, channels);
+                FutureReaper reaperFuture = new FutureReaper(future, config, isClose, channels);
                 Future<?> scheduledFuture = config.reaper().scheduleAtFixedRate(reaperFuture, 0, schedulePeriod, TimeUnit.MILLISECONDS);
                 reaperFuture.setScheduledFuture(scheduledFuture);
                 future.setReaperFuture(reaperFuture);

providers/netty4/src/main/java/org/asynchttpclient/providers/netty4/NettyResponseFuture.java

@@ -69,7 +69,7 @@ public enum STATE {
     private HttpResponse httpResponse;
     private final AtomicReference<ExecutionException> exEx = new AtomicReference<ExecutionException>();
     private final AtomicInteger redirectCount = new AtomicInteger();
-    private volatile ReaperFuture reaperFuture;
+    private volatile FutureReaper reaperFuture;
     private final AtomicBoolean inAuth = new AtomicBoolean(false);
     private final AtomicBoolean statusReceived = new AtomicBoolean(false);
     private final AtomicLong touch = new AtomicLong(millisTime());
@@ -358,7 +358,7 @@ public int incrementAndGetCurrentRedirectCount() {
         return redirectCount.incrementAndGet();
     }
 
-    public void setReaperFuture(ReaperFuture reaperFuture) {
+    public void setReaperFuture(FutureReaper reaperFuture) {
         cancelReaper();
         this.reaperFuture = reaperFuture;
     }