Fix typos (AsyncHttpClient#1752)

* Fix typos

* Fix Failing Github Actions Tests (AsyncHttpClient#1753)

* Bump GitHub Actions runner version to Ubuntu 20.04

* AsyncStreamHandlerTest.asyncOptionsTest - Allow for the appearance of the TRACE method in the server's response

* MaxTotalConnectionTest.testMaxTotalConnections - https://github.com --> https://www.youtube.com, https://google.com --> https://www.google.com 

* TextMessageTest.onFailureTest - Refactor logic for more granular testing (accept ConnectException in addition to UnknownHostException, but check for "DNS Name not found" in exception cause)

Co-authored-by: Tom Granot <[email protected]>

Author: LorenzNickel

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

@@ -255,7 +255,7 @@ public interface AsyncHttpClientConfig {
   String[] getEnabledCipherSuites();
 
   /**
-   * @return if insecured cipher suites must be filtered out (only used when not explicitly passing enabled cipher suites)
+   * @return if insecure cipher suites must be filtered out (only used when not explicitly passing enabled cipher suites)
    */
   boolean isFilterInsecureCipherSuites();
 

client/src/main/java/org/asynchttpclient/handler/resumable/ResumableListener.java

@@ -29,7 +29,7 @@ public interface ResumableListener {
   void onBytesReceived(ByteBuffer byteBuffer) throws IOException;
 
   /**
-   * Invoked when all the bytes has been sucessfully transferred.
+   * Invoked when all the bytes has been successfully transferred.
    */
   void onAllBytesReceived();
 

client/src/main/java/org/asynchttpclient/netty/channel/ChannelManager.java

@@ -342,15 +342,15 @@ private SslHandler createSslHandler(String peerHost, int peerPort) {
 
   public Future<Channel> updatePipelineForHttpTunneling(ChannelPipeline pipeline, Uri requestUri) {
 
-    Future<Channel> whenHanshaked = null;
+    Future<Channel> whenHandshaked = null;
 
     if (pipeline.get(HTTP_CLIENT_CODEC) != null)
       pipeline.remove(HTTP_CLIENT_CODEC);
 
     if (requestUri.isSecured()) {
       if (!isSslHandlerConfigured(pipeline)) {
         SslHandler sslHandler = createSslHandler(requestUri.getHost(), requestUri.getExplicitPort());
-        whenHanshaked = sslHandler.handshakeFuture();
+        whenHandshaked = sslHandler.handshakeFuture();
         pipeline.addBefore(INFLATER_HANDLER, SSL_HANDLER, sslHandler);
       }
       pipeline.addAfter(SSL_HANDLER, HTTP_CLIENT_CODEC, newHttpClientCodec());
@@ -368,7 +368,7 @@ public Future<Channel> updatePipelineForHttpTunneling(ChannelPipeline pipeline,
 
       pipeline.remove(AHC_HTTP_HANDLER);
     }
-    return whenHanshaked;
+    return whenHandshaked;
   }
 
   public SslHandler addSslHandler(ChannelPipeline pipeline, Uri uri, String virtualHost, boolean hasSocksProxyHandler) {

client/src/main/java/org/asynchttpclient/request/body/multipart/FileLikePart.java

@@ -47,14 +47,14 @@ public abstract class FileLikePart extends PartBase {
    * @param charset           the charset encoding for this part
    * @param fileName          the fileName
    * @param contentId         the content id
-   * @param transfertEncoding the transfer encoding
+   * @param transferEncoding the transfer encoding
    */
-  public FileLikePart(String name, String contentType, Charset charset, String fileName, String contentId, String transfertEncoding) {
+  public FileLikePart(String name, String contentType, Charset charset, String fileName, String contentId, String transferEncoding) {
     super(name,
             computeContentType(contentType, fileName),
             charset,
             contentId,
-            transfertEncoding);
+            transferEncoding);
     this.fileName = fileName;
   }
 

client/src/main/java/org/asynchttpclient/request/body/multipart/PartBase.java

@@ -127,7 +127,7 @@ public String toString() {
             " name=" + getName() +
             " contentType=" + getContentType() +
             " charset=" + getCharset() +
-            " tranferEncoding=" + getTransferEncoding() +
+            " transferEncoding=" + getTransferEncoding() +
             " contentId=" + getContentId() +
             " dispositionType=" + getDispositionType();
   }

client/src/main/java/org/asynchttpclient/spnego/NamePasswordCallbackHandler.java

@@ -57,7 +57,7 @@ protected boolean handleCallback(Callback callback) {
   /*
    * This method is called from the handle(Callback[]) method when the specified callback
    * did not match any of the known callback classes. It looks for the callback method
-   * having the specified method name with one of the suppported parameter types.
+   * having the specified method name with one of the supported parameter types.
    * If found, it invokes the callback method on the object and returns true.
    * If not, it returns false.
    */

client/src/main/java/org/asynchttpclient/util/StringBuilderPool.java

@@ -19,7 +19,7 @@ public class StringBuilderPool {
   private final ThreadLocal<StringBuilder> pool = ThreadLocal.withInitial(() -> new StringBuilder(512));
 
   /**
-   * BEWARE: MUSN'T APPEND TO ITSELF!
+   * BEWARE: MUSTN'T APPEND TO ITSELF!
    *
    * @return a pooled StringBuilder
    */

client/src/test/java/org/asynchttpclient/BasicAuthTest.java

@@ -65,7 +65,7 @@ public void setUpGlobal() throws Exception {
     server2.start();
     port2 = connector2.getLocalPort();
 
-    // need noAuth server to verify the preemptive auth mode (see basicAuthTestPreemtiveTest)
+    // need noAuth server to verify the preemptive auth mode (see basicAuthTestPreemptiveTest)
     serverNoAuth = new Server();
     ServerConnector connectorNoAuth = addHttpConnector(serverNoAuth);
     serverNoAuth.setHandler(new SimpleHandler());
@@ -170,7 +170,7 @@ public Integer onCompleted() {
   }
 
   @Test
-  public void basicAuthTestPreemtiveTest() throws IOException, ExecutionException, TimeoutException, InterruptedException {
+  public void basicAuthTestPreemptiveTest() throws IOException, ExecutionException, TimeoutException, InterruptedException {
     try (AsyncHttpClient client = asyncHttpClient()) {
       // send the request to the no-auth endpoint to be able to verify the
       // auth header is really sent preemptively for the initial call.

client/src/test/java/org/asynchttpclient/BasicHttpTest.java

@@ -788,7 +788,7 @@ public void onThrowable(Throwable t) {
   }
 
   @Test
-  public void nonBlockingNestedRequetsFromIoThreadAreFine() throws Throwable {
+  public void nonBlockingNestedRequestsFromIoThreadAreFine() throws Throwable {
     withClient().run(client ->
       withServer(server).run(server -> {
 

client/src/test/java/org/asynchttpclient/handler/resumable/PropertiesBasedResumableProcesserTest.java renamed to client/src/test/java/org/asynchttpclient/handler/resumable/PropertiesBasedResumableProcessorTest.java

@@ -21,7 +21,7 @@
 /**
  * @author Benjamin Hanzelmann
  */
-public class PropertiesBasedResumableProcesserTest {
+public class PropertiesBasedResumableProcessorTest {
 
   @Test
   public void testSaveLoad() {

client/src/test/java/org/asynchttpclient/reactivestreams/ReactiveStreamsDownloadTest.java

@@ -93,7 +93,7 @@ static protected class SimpleStreamedAsyncHandler implements StreamedAsyncHandle
 
     @Override
     public State onStream(Publisher<HttpResponseBodyPart> publisher) {
-      LOGGER.debug("SimpleStreamedAsyncHandleronCompleted onStream");
+      LOGGER.debug("SimpleStreamedAsyncHandlerOnCompleted onStream");
       publisher.subscribe(subscriber);
       return State.CONTINUE;
     }
@@ -105,7 +105,7 @@ public void onThrowable(Throwable t) {
 
     @Override
     public State onBodyPartReceived(HttpResponseBodyPart bodyPart) {
-      LOGGER.debug("SimpleStreamedAsyncHandleronCompleted onBodyPartReceived");
+      LOGGER.debug("SimpleStreamedAsyncHandlerOnCompleted onBodyPartReceived");
       throw new AssertionError("Should not have received body part");
     }
 
@@ -121,7 +121,7 @@ public State onHeadersReceived(HttpHeaders headers) {
 
     @Override
     public SimpleStreamedAsyncHandler onCompleted() {
-      LOGGER.debug("SimpleStreamedAsyncHandleronCompleted onSubscribe");
+      LOGGER.debug("SimpleStreamedAsyncHandlerOnCompleted onSubscribe");
       return this;
     }
 

client/src/test/java/org/asynchttpclient/request/body/ChunkingTest.java

@@ -33,7 +33,7 @@
 public class ChunkingTest extends AbstractBasicTest {
 
   // So we can just test the returned data is the image,
-  // and doesn't contain the chunked delimeters.
+  // and doesn't contain the chunked delimiters.
   @Test
   public void testBufferLargerThanFileWithStreamBodyGenerator() throws Throwable {
     doTestWithInputStreamBodyGenerator(new BufferedInputStream(Files.newInputStream(LARGE_IMAGE_FILE.toPath()), 400000));

client/src/test/java/org/asynchttpclient/request/body/FilePartLargeFileTest.java

@@ -51,7 +51,7 @@ public void handle(String target, Request baseRequest, HttpServletRequest req, H
           total += count;
         }
         resp.setStatus(200);
-        resp.addHeader("X-TRANFERED", String.valueOf(total));
+        resp.addHeader("X-TRANSFERRED", String.valueOf(total));
         resp.getOutputStream().flush();
         resp.getOutputStream().close();
 

client/src/test/java/org/asynchttpclient/request/body/TransferListenerTest.java

@@ -98,8 +98,8 @@ public void basicPutFileTest() throws Exception {
     final AtomicReference<Throwable> throwable = new AtomicReference<>();
     final AtomicReference<HttpHeaders> hSent = new AtomicReference<>();
     final AtomicReference<HttpHeaders> hRead = new AtomicReference<>();
-    final AtomicInteger bbReceivedLenght = new AtomicInteger(0);
-    final AtomicLong bbSentLenght = new AtomicLong(0L);
+    final AtomicInteger bbReceivedLength = new AtomicInteger(0);
+    final AtomicLong bbSentLength = new AtomicLong(0L);
 
     final AtomicBoolean completed = new AtomicBoolean(false);
 
@@ -120,11 +120,11 @@ public void onResponseHeadersReceived(HttpHeaders headers) {
         }
 
         public void onBytesReceived(byte[] b) {
-          bbReceivedLenght.addAndGet(b.length);
+          bbReceivedLength.addAndGet(b.length);
         }
 
         public void onBytesSent(long amount, long current, long total) {
-          bbSentLenght.addAndGet(amount);
+          bbSentLength.addAndGet(amount);
         }
 
         public void onRequestResponseCompleted() {
@@ -142,8 +142,8 @@ public void onThrowable(Throwable t) {
       assertEquals(response.getStatusCode(), 200);
       assertNotNull(hRead.get());
       assertNotNull(hSent.get());
-      assertEquals(bbReceivedLenght.get(), file.length(), "Number of received bytes incorrect");
-      assertEquals(bbSentLenght.get(), file.length(), "Number of sent bytes incorrect");
+      assertEquals(bbReceivedLength.get(), file.length(), "Number of received bytes incorrect");
+      assertEquals(bbSentLength.get(), file.length(), "Number of sent bytes incorrect");
     }
   }
 
@@ -153,8 +153,8 @@ public void basicPutFileBodyGeneratorTest() throws Exception {
       final AtomicReference<Throwable> throwable = new AtomicReference<>();
       final AtomicReference<HttpHeaders> hSent = new AtomicReference<>();
       final AtomicReference<HttpHeaders> hRead = new AtomicReference<>();
-      final AtomicInteger bbReceivedLenght = new AtomicInteger(0);
-      final AtomicLong bbSentLenght = new AtomicLong(0L);
+      final AtomicInteger bbReceivedLength = new AtomicInteger(0);
+      final AtomicLong bbSentLength = new AtomicLong(0L);
 
       final AtomicBoolean completed = new AtomicBoolean(false);
 
@@ -172,11 +172,11 @@ public void onResponseHeadersReceived(HttpHeaders headers) {
         }
 
         public void onBytesReceived(byte[] b) {
-          bbReceivedLenght.addAndGet(b.length);
+          bbReceivedLength.addAndGet(b.length);
         }
 
         public void onBytesSent(long amount, long current, long total) {
-          bbSentLenght.addAndGet(amount);
+          bbSentLength.addAndGet(amount);
         }
 
         public void onRequestResponseCompleted() {
@@ -194,8 +194,8 @@ public void onThrowable(Throwable t) {
       assertEquals(response.getStatusCode(), 200);
       assertNotNull(hRead.get());
       assertNotNull(hSent.get());
-      assertEquals(bbReceivedLenght.get(), file.length(), "Number of received bytes incorrect");
-      assertEquals(bbSentLenght.get(), file.length(), "Number of sent bytes incorrect");
+      assertEquals(bbReceivedLength.get(), file.length(), "Number of received bytes incorrect");
+      assertEquals(bbSentLength.get(), file.length(), "Number of sent bytes incorrect");
     }
   }
 

client/src/test/java/org/asynchttpclient/request/body/multipart/MultipartBodyTest.java

@@ -122,8 +122,8 @@ public int write(ByteBuffer src) {
   public void transferWithCopy() throws Exception {
     for (int bufferLength = 1; bufferLength < MAX_MULTIPART_CONTENT_LENGTH_ESTIMATE + 1; bufferLength++) {
       try (MultipartBody multipartBody = buildMultipart()) {
-        long tranferred = transferWithCopy(multipartBody, bufferLength);
-        assertEquals(tranferred, multipartBody.getContentLength());
+        long transferred = transferWithCopy(multipartBody, bufferLength);
+        assertEquals(transferred, multipartBody.getContentLength());
       }
     }
   }
@@ -132,8 +132,8 @@ public void transferWithCopy() throws Exception {
   public void transferZeroCopy() throws Exception {
     for (int bufferLength = 1; bufferLength < MAX_MULTIPART_CONTENT_LENGTH_ESTIMATE + 1; bufferLength++) {
       try (MultipartBody multipartBody = buildMultipart()) {
-        long tranferred = transferZeroCopy(multipartBody, bufferLength);
-        assertEquals(tranferred, multipartBody.getContentLength());
+        long transferred = transferZeroCopy(multipartBody, bufferLength);
+        assertEquals(transferred, multipartBody.getContentLength());
       }
     }
   }

client/src/test/java/org/asynchttpclient/request/body/multipart/part/MultipartPartTest.java

@@ -239,12 +239,12 @@ private class TestFileLikePart extends FileLikePart {
       this(name, contentType, charset, contentId, null);
     }
 
-    TestFileLikePart(String name, String contentType, Charset charset, String contentId, String transfertEncoding) {
-      this(name, contentType, charset, contentId, transfertEncoding, null);
+    TestFileLikePart(String name, String contentType, Charset charset, String contentId, String transferEncoding) {
+      this(name, contentType, charset, contentId, transferEncoding, null);
     }
 
-    TestFileLikePart(String name, String contentType, Charset charset, String contentId, String transfertEncoding, String fileName) {
-      super(name, contentType, charset, fileName, contentId, transfertEncoding);
+    TestFileLikePart(String name, String contentType, Charset charset, String contentId, String transferEncoding, String fileName) {
+      super(name, contentType, charset, fileName, contentId, transferEncoding);
     }
   }
 

extras/guava/src/main/java/org/asynchttpclient/extras/guava/RateLimitedThrottleRequestFilter.java

@@ -13,7 +13,7 @@
  * {@link ThrottleRequestFilter} by allowing rate limiting per second in addition to the
  * number of concurrent connections.
  * <p>
- * The <code>maxWaitMs</code> argument is respected accross both permit acquistions. For
+ * The <code>maxWaitMs</code> argument is respected across both permit acquisitions. For
  * example, if 1000 ms is given, and the filter spends 500 ms waiting for a connection,
  * it will only spend another 500 ms waiting for the rate limiter.
  */
@@ -44,9 +44,9 @@ public <T> FilterContext<T> filter(FilterContext<T> ctx) throws FilterException
       }
 
       long startOfWait = System.currentTimeMillis();
-      attemptConcurrencyPermitAcquistion(ctx);
+      attemptConcurrencyPermitAcquisition(ctx);
 
-      attemptRateLimitedPermitAcquistion(ctx, startOfWait);
+      attemptRateLimitedPermitAcquisition(ctx, startOfWait);
     } catch (InterruptedException e) {
       throw new FilterException(String.format("Interrupted Request %s with AsyncHandler %s", ctx.getRequest(), ctx.getAsyncHandler()));
     }
@@ -56,7 +56,7 @@ public <T> FilterContext<T> filter(FilterContext<T> ctx) throws FilterException
             .build();
   }
 
-  private <T> void attemptRateLimitedPermitAcquistion(FilterContext<T> ctx, long startOfWait) throws FilterException {
+  private <T> void attemptRateLimitedPermitAcquisition(FilterContext<T> ctx, long startOfWait) throws FilterException {
     long wait = getMillisRemainingInMaxWait(startOfWait);
 
     if (!rateLimiter.tryAcquire(wait, TimeUnit.MILLISECONDS)) {
@@ -65,7 +65,7 @@ private <T> void attemptRateLimitedPermitAcquistion(FilterContext<T> ctx, long s
     }
   }
 
-  private <T> void attemptConcurrencyPermitAcquistion(FilterContext<T> ctx) throws InterruptedException, FilterException {
+  private <T> void attemptConcurrencyPermitAcquisition(FilterContext<T> ctx) throws InterruptedException, FilterException {
     if (!available.tryAcquire(maxWaitMs, TimeUnit.MILLISECONDS)) {
       throw new FilterException(String.format("No slot available for processing Request %s with AsyncHandler %s", ctx.getRequest(),
               ctx.getAsyncHandler()));

extras/registry/src/main/java/org/asynchttpclient/extras/registry/AsyncHttpClientFactory.java

@@ -33,7 +33,7 @@
  * an instance of that class. If there is an exception while reading the
  * properties file or system property it throws a RuntimeException
  * AsyncHttpClientImplException. If any of the constructors of the instance
- * throws an exception it thows a AsyncHttpClientImplException. By default if
+ * throws an exception it throws a AsyncHttpClientImplException. By default if
  * neither the system property or the property file exists then it will return
  * the default instance of {@link DefaultAsyncHttpClient}
  */

extras/rxjava2/src/main/java/org/asynchttpclient/extras/rxjava2/RxHttpClient.java

@@ -57,7 +57,7 @@ default Maybe<Response> prepare(Request request) {
    * @param request         the request that is to be executed
    * @param handlerSupplier supplies the desired {@code AsyncHandler} instances that are used to produce results
    * @return a {@code Maybe} that executes {@code request} upon subscription and that emits the results produced by
-   * the supplied handers
+   * the supplied handlers
    * @throws NullPointerException if at least one of the parameters is {@code null}
    */
   <T> Maybe<T> prepare(Request request, Supplier<? extends AsyncHandler<T>> handlerSupplier);

extras/rxjava2/src/main/java/org/asynchttpclient/extras/rxjava2/maybe/AbstractMaybeAsyncHandlerBridge.java

@@ -94,7 +94,7 @@ public State onTrailingHeadersReceived(HttpHeaders headers) throws Exception {
    * {@inheritDoc}
    * <p>
    * <p>
-   * The value returned by the wrapped {@code AsyncHandler} won't be returned by this method, but emtited via RxJava.
+   * The value returned by the wrapped {@code AsyncHandler} won't be returned by this method, but emitted via RxJava.
    * </p>
    *
    * @return always {@code null}

extras/rxjava2/src/test/java/org/asynchttpclient/extras/rxjava2/DefaultRxHttpClientTest.java

@@ -61,7 +61,7 @@ public class DefaultRxHttpClientTest {
   private ArgumentCaptor<AsyncHandler<Object>> handlerCaptor;
 
   @Mock
-  private ListenableFuture<Object> resposeFuture;
+  private ListenableFuture<Object> responseFuture;
 
   @InjectMocks
   private DefaultRxHttpClient underTest;
@@ -148,15 +148,15 @@ public void callsSupplierForEachSubscription() {
   @Test
   public void cancelsResponseFutureOnDispose() throws Exception {
     given(handlerSupplier.get()).willReturn(handler);
-    given(asyncHttpClient.executeRequest(eq(request), any())).willReturn(resposeFuture);
+    given(asyncHttpClient.executeRequest(eq(request), any())).willReturn(responseFuture);
 
     /* when */
     underTest.prepare(request, handlerSupplier).subscribe().dispose();
 
     // then
     then(asyncHttpClient).should().executeRequest(eq(request), handlerCaptor.capture());
     final AsyncHandler<Object> bridge = handlerCaptor.getValue();
-    then(resposeFuture).should().cancel(true);
+    then(responseFuture).should().cancel(true);
     verifyZeroInteractions(handler);
     assertThat(bridge.onStatusReceived(null), is(AsyncHandler.State.ABORT));
     verify(handler).onThrowable(isA(DisposedException.class));

extras/simple/src/main/java/org/asynchttpclient/extras/simple/ResumableBodyConsumer.java

@@ -30,7 +30,7 @@ public interface ResumableBodyConsumer extends BodyConsumer {
   /**
    * Get the previously transferred bytes, for example the current file size.
    *
-   * @return the number of tranferred bytes
+   * @return the number of transferred bytes
    * @throws IOException IO exception
    */
   long getTransferredBytes() throws IOException;

extras/simple/src/main/java/org/asynchttpclient/extras/simple/SimpleAsyncHttpClient.java

@@ -505,8 +505,8 @@ public Builder setMaxConnectionsPerHost(int defaultMaxConnectionsPerHost) {
       return this;
     }
 
-    public Builder setConnectTimeout(int connectTimeuot) {
-      configBuilder.setConnectTimeout(connectTimeuot);
+    public Builder setConnectTimeout(int connectTimeout) {
+      configBuilder.setConnectTimeout(connectTimeout);
       return this;
     }