JavaDoc Improvement (#1905)

Author: hyperxpro

client/src/main/java/org/asynchttpclient/AsyncCompletionHandlerBase.java

@@ -23,6 +23,7 @@
  * Simple {@link AsyncHandler} of type {@link Response}
  */
 public class AsyncCompletionHandlerBase extends AsyncCompletionHandler<Response> {
+
     @Override
     public @Nullable Response onCompleted(@Nullable Response response) throws Exception {
         return response;

client/src/main/java/org/asynchttpclient/DefaultAsyncHttpClient.java

@@ -40,7 +40,7 @@
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.function.Predicate;
 
-import static org.asynchttpclient.util.Assertions.assertNotNull;
+import static java.util.Objects.requireNonNull;
 import static org.asynchttpclient.util.HttpConstants.Methods.CONNECT;
 import static org.asynchttpclient.util.HttpConstants.Methods.DELETE;
 import static org.asynchttpclient.util.HttpConstants.Methods.GET;
@@ -294,7 +294,7 @@ private <T> ListenableFuture<T> execute(Request request, final AsyncHandler<T> a
     private <T> FilterContext<T> preProcessRequest(FilterContext<T> fc) throws FilterException {
         for (RequestFilter asyncFilter : config.getRequestFilters()) {
             fc = asyncFilter.filter(fc);
-            assertNotNull(fc, "filterContext");
+            requireNonNull(fc, "filterContext");
         }
 
         Request request = fc.getRequest();

client/src/main/java/org/asynchttpclient/Realm.java

@@ -29,7 +29,7 @@
 
 import static java.nio.charset.StandardCharsets.ISO_8859_1;
 import static java.nio.charset.StandardCharsets.UTF_8;
-import static org.asynchttpclient.util.Assertions.assertNotNull;
+import static java.util.Objects.requireNonNull;
 import static org.asynchttpclient.util.HttpConstants.Methods.GET;
 import static org.asynchttpclient.util.MessageDigestUtils.pooledMd5MessageDigest;
 import static org.asynchttpclient.util.MiscUtils.isNonEmpty;
@@ -92,7 +92,7 @@ private Realm(@Nullable AuthScheme scheme,
                   @Nullable Map<String, String> customLoginConfig,
                   @Nullable String loginContextName) {
 
-        this.scheme = assertNotNull(scheme, "scheme");
+        this.scheme = requireNonNull(scheme, "scheme");
         this.principal = principal;
         this.password = password;
         this.realmName = realmName;

client/src/main/java/org/asynchttpclient/channel/NoopChannelPool.java

@@ -22,38 +22,69 @@
 import java.util.Map;
 import java.util.function.Predicate;
 
+/**
+ * A {@link ChannelPool} implementation that doesn't pool anything.
+ */
 public enum NoopChannelPool implements ChannelPool {
 
     INSTANCE;
 
+    /**
+     *
+     * @return always false since this is a {@link NoopChannelPool}
+     */
     @Override
     public boolean offer(Channel channel, Object partitionKey) {
         return false;
     }
 
+    /**
+     *
+     * @return always null since this is a {@link NoopChannelPool}
+     */
     @Override
     public @Nullable Channel poll(Object partitionKey) {
         return null;
     }
 
+    /**
+     *
+     * @return always false since this is a {@link NoopChannelPool}
+     */
     @Override
     public boolean removeAll(Channel channel) {
         return false;
     }
 
+    /**
+     *
+     * @return always true since this is a {@link NoopChannelPool}
+     */
     @Override
     public boolean isOpen() {
         return true;
     }
 
+    /**
+     *
+     * Does nothing since this is a {@link NoopChannelPool}
+     */
     @Override
     public void destroy() {
     }
 
+    /**
+     *
+     * Does nothing since this is a {@link NoopChannelPool}
+     */
     @Override
     public void flushPartitions(Predicate<Object> predicate) {
     }
 
+    /**
+     *
+     * @return always {@link Collections#emptyMap()} since this is a {@link NoopChannelPool}
+     */
     @Override
     public Map<String, Long> getIdleChannelCountPerHost() {
         return Collections.emptyMap();

client/src/main/java/org/asynchttpclient/config/AsyncHttpClientConfigHelper.java

@@ -64,18 +64,29 @@ public void reload() {
             propsCache.clear();
         }
 
+        /**
+         * Parse a property file.
+         *
+         * @param file     the file to parse
+         * @param required if true, the file must be present
+         * @return the parsed properties
+         * @throws RuntimeException if the file is required and not present or if the file can't be parsed
+         */
         private Properties parsePropertiesFile(String file, boolean required) {
             Properties props = new Properties();
 
-            InputStream is = getClass().getResourceAsStream(file);
-            if (is != null) {
-                try {
-                    props.load(is);
-                } catch (IOException e) {
-                    throw new IllegalArgumentException("Can't parse config file " + file, e);
+            try (InputStream is = getClass().getResourceAsStream(file)) {
+                if (is != null) {
+                    try {
+                        props.load(is);
+                    } catch (IOException e) {
+                        throw new IllegalArgumentException("Can't parse config file " + file, e);
+                    }
+                } else if (required) {
+                    throw new IllegalArgumentException("Can't locate config file " + file);
                 }
-            } else if (required) {
-                throw new IllegalArgumentException("Can't locate config file " + file);
+            } catch (IOException e) {
+                throw new RuntimeException(e);
             }
 
             return props;

client/src/main/java/org/asynchttpclient/cookie/ThreadSafeCookieStore.java

@@ -17,7 +17,6 @@
 
 import io.netty.handler.codec.http.cookie.Cookie;
 import org.asynchttpclient.uri.Uri;
-import org.asynchttpclient.util.Assertions;
 import org.asynchttpclient.util.MiscUtils;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
@@ -34,6 +33,8 @@
 import java.util.function.Predicate;
 import java.util.stream.Collectors;
 
+import static java.util.Objects.requireNonNull;
+
 public final class ThreadSafeCookieStore implements CookieStore {
 
     private final Map<String, Map<CookieKey, StoredCookie>> cookieJar = new ConcurrentHashMap<>();
@@ -88,7 +89,6 @@ public void evictExpired() {
         removeExpired();
     }
 
-
     @Override
     public int incrementAndGet() {
         return counter.incrementAndGet();
@@ -226,8 +226,11 @@ private List<Cookie> getStoredCookies(String domain, String path, boolean secure
 
     private void removeExpired() {
         final boolean[] removed = {false};
-        cookieJar.values().forEach(cookieMap -> removed[0] |= cookieMap.entrySet().removeIf(
-                v -> hasCookieExpired(v.getValue().cookie, v.getValue().createdAt)));
+
+        cookieJar.values()
+                .forEach(cookieMap -> removed[0] |= cookieMap.entrySet()
+                .removeIf(v -> hasCookieExpired(v.getValue().cookie, v.getValue().createdAt)));
+
         if (removed[0]) {
             cookieJar.entrySet().removeIf(entry -> entry.getValue() == null || entry.getValue().isEmpty());
         }
@@ -243,11 +246,12 @@ private static class CookieKey implements Comparable<CookieKey> {
         }
 
         @Override
-        public int compareTo(@NotNull CookieKey o) {
-            Assertions.assertNotNull(o, "Parameter can't be null");
+        public int compareTo(@NotNull CookieKey cookieKey) {
+            requireNonNull(cookieKey, "Parameter can't be null");
+
             int result;
-            if ((result = name.compareTo(o.name)) == 0) {
-                result = path.compareTo(o.path);
+            if ((result = name.compareTo(cookieKey.name)) == 0) {
+                result = path.compareTo(cookieKey.path);
             }
             return result;
         }

client/src/main/java/org/asynchttpclient/exception/ChannelClosedException.java

@@ -19,7 +19,11 @@
 
 import static org.asynchttpclient.util.ThrowableUtil.unknownStackTrace;
 
+/**
+ * This exception is thrown when a channel is closed.
+ */
 public final class ChannelClosedException extends IOException {
+
     private static final long serialVersionUID = -2528693697240456658L;
     public static final ChannelClosedException INSTANCE = unknownStackTrace(new ChannelClosedException(), ChannelClosedException.class, "INSTANCE");
 

client/src/main/java/org/asynchttpclient/exception/PoolAlreadyClosedException.java

@@ -19,7 +19,11 @@
 
 import static org.asynchttpclient.util.ThrowableUtil.unknownStackTrace;
 
+/**
+ * This exception is thrown when a channel pool is already closed.
+ */
 public class PoolAlreadyClosedException extends IOException {
+
     private static final long serialVersionUID = -3883404852005245296L;
     public static final PoolAlreadyClosedException INSTANCE = unknownStackTrace(new PoolAlreadyClosedException(), PoolAlreadyClosedException.class, "INSTANCE");
 

client/src/main/java/org/asynchttpclient/exception/RemotelyClosedException.java

@@ -19,7 +19,11 @@
 
 import static org.asynchttpclient.util.ThrowableUtil.unknownStackTrace;
 
+/**
+ * This exception is thrown when a channel is closed by remote host.
+ */
 public final class RemotelyClosedException extends IOException {
+
     private static final long serialVersionUID = 5634105738124356785L;
     public static final RemotelyClosedException INSTANCE = unknownStackTrace(new RemotelyClosedException(), RemotelyClosedException.class, "INSTANCE");
 

client/src/main/java/org/asynchttpclient/exception/TooManyConnectionsException.java

@@ -17,6 +17,9 @@
 
 import java.io.IOException;
 
+/**
+ * This exception is thrown when too many connections are opened.
+ */
 public class TooManyConnectionsException extends IOException {
     private static final long serialVersionUID = 8645586459539317237L;