Remote repo configuration version 2.8.1

.travis.yml

@@ -2,26 +2,22 @@ dist: xenial
 language: minimal
 sudo: true
 services:
-  - docker
-
+- docker
 env:
   global:
-    - SERVICE_NAME=async-http-client
-    - REVISION=2.5.3-SNAPSHOT
-    - secure: vto8UyM7tMHE4tUwxmYC150orDzrz/6b33m8V6+yh1uHWJmtqhyshsjLKFMmiqkAHz/7jmrgMMlHcnYJ27IyNJsqd4WNQfUjf9nRuizbRKD+yhy7R+IKbgy8bSYizyvQ/4T07sJkOcebzXJigTlOjxpwDfKgBj7vqr5paXrir0Srs0jjgyMxnASFYaBvy2i6wPyPqslkbwHwTapWg3porl/EmSj9rmgHVnPED5CPYraMp+zTHJCpP6xgGn1N3wS+x3sUDZ4MSHeZLXbaSzmIIUBNbYSUjOnEspD0Pi/78G1cl6sW7KiSIAt+H6hoy1+rU6J4RyB8M6pSvNJDlgnYfemG/6onTAXA5n/0+dcs1X2skA3GscOmPoEUuPYyKeQwk2eXK67UC7LNSu1HSAeIxPgwKv4axmFPv/2GJtM70HP28cR35gzyWMMhsxGT7tuKE7W83bEuT/nUzXCWCC80LCOpRRHvfxczUO7bFDE9Be4K/xKtIAJiHZimcvixRoxRojPVSr8DrmeSFA+oGgE6F0hW6cQDynqF7FlmIb+6h3DVPWegQZqi7RP3UHy2qSwj2gAYAydd6FHib7juc8K4xIDdgZ53reCmQL6ULEwKF2unWDxLZ3urqDmhIc3qRH6it9VWdKoNr25EDgKXMVfiGoeKeZBVAl0KtdD6kDgLE9Q=
-    - secure: mLmKxZKFaaa98pVHMMcF/XEoXIebrOX7B9ZSLdGeB/2N9PWQnTRRThLrbd2gY1mpxPW+Nu6Nn4M0eh0g0kfYpypaetq7RO8GtNgRDW7qNDTr3q+dcV0+xW2YC+sAhvOnTMu8uz0bHf1y6iQMMvjggU9pyBD9iGtcANn5WXg+UW9cnlvx44MIzpKXt9RzItNpRgTC2/z+j8QL5zjwpMB2xT6EuP7ZFj1xnCQTAZ04qdOmM9Ro7rpvw0zYUIsYuEiyZMIgaGAsaGr00+VpbM9yRQTx7gGjvU6DLs3NfjJrl9ZyaR/vofAGjeV8DBNWBJwL6faq3y091joLIsWv4+tDfh+SZVwbUUhhHZUS0tuqebC0XAQMR5SAfOcO7t7blu9zk3esaeGYWaahQ3Jy1XupvuRQRu9Uj2p5tQTNRrDN9/8l4a9lwdhruDeHUeAwT1UGyx68WhXppWHuHw/Gbt20mo6nspuFPVJ5JrqdYrcfL4dUs+XY2sg4esweivOfrUy7F0noA85/Ol14P2wHyVp4aO+Bc8R+g87MxVlPm+vyW2YJQOi9EYFnPc6YyCu/RbXjvGh6y8izAN6BojeRJ9OJZjRZCG2s9CgL7a75ZOJEQ/ADpnJyhjD6XPlq7ZLwrh0j9fKLTYpk/zh26Ws/ZtGi0sMlwIXotGzVrIQUGgOmS00=
-    - secure: DPh5/VR6H3TSzReXgN6HVUoS7nvBX6nchs4esS0jLc/H34wAhC87d8g/8rn7GOvlf/jfr3ujUdl9EFGEy5WjfhNJYDqD/lLz2FmeNh8mI5ZX6mAhmd1CI7ow3miT/Dj/jdY/felWjgWRQIZRaYAv+qwoT96JSSEIO4lpfzafp4lXeD9oKp5t2Uk+Afz41x+e/OCoOW1VtUZi9VEiKbxcQCrwZRuHptTveJCi86zPeIokuUT+BBs0qQur960bq0c+XpkOC6tg3SLIQJJ/OSariiGfuap/A8ZObn9YFprmUYUUV9X8sOPuCBMOMQkqeG9DxNGEloHa9Xi+QpLTfFuLPvyp+PhZVYlMLvsH2GeWLNimlBqENaeKt/2DcO6pwf5TB0JcpV5tEPcjI3QVuqUEk6oXpwwAdoff4bN6Uafo3vKyQXEAsr26b590kxAhKxpI7nPmYtvHSkCfVxLh5Q2R6C0dpaGdamBRKjD+Lku2PJXE+lErk5SnK2BgBkiuuBaxVvUYO9RatucVVne+VDTJY6brcXJEEDs/myfK6lpF2cb5BM14l58iHWBQHmiDhGyl3CKRVXpavG9IuuVMf7siV0957ixCZstlU7J4RDwunGrl6RM3BQdj55atnHu+AKuy3piVy+NX+IimiaRsWw+N04pO3sAakG0fMa1YQ55RDOQ=
-    - secure: eZclfJ0N5XzH4Y8ZzLrbcX6iv9Mgc4gctU//jNTN39U2qlBvSUiuY3GDwZfPZjC/V0aeS1+Kb/NBeHaOTfEcqd3+nn4lYrEz3Aqi3NJoapgcWtcQDwIs9edRoJLxZ2iRJJqMY0ONTDur5qgAw+21Pk1KCHFMYVwHcXuOqf5fGTxhi0m1qSEHXJUNnVHP9mAwcF9YvmePeBi/s9RU/E6vHjjg7ZH//JTnGYERn9EqygXwFP+BKx+HrI+8mzmgOiZvwJkUrA6Yk6Z0QIcMiBfIVKm8AdQr4lo8UtZcm1YWz4z0wnN24UxKf3PwKy9Br9Ol2T4nLlAfRYBmNF6HM/nsC+TENfelZvp8xkH79hsdSfCNoWS5Ir1LgvKGJ/Nr/msM80bvBOqsqeT3MaInuWVRfAVhYlFhqUHuVSQf74qbSYXCyMnUR5GYZ6ZY/aYcXw1bFDmBLBRroMw4E76NLsmqoAU8Cq9PaZIqsGGt5fqv5tJMEPaAWr0tNwywtVVoLV3wZh15dClMRkfvrYEUuSBLw0neAHDVNz4UYvySfQgAtDIndxR9lwoBssMGi4zNVfFJ/kAFSTaWoiwu2Q7dp4LJIgG1ZHvUV1uICZhd9rPjEjS83FNCSAt1WBX7r8hLbBLhZBjl7dMl4CQqW4xC6JjzHjACiHGpjoyBBy9arrxg4PU=
-
+  - SERVICE_NAME=async-http-client
+  - REVISION=$(git rev-parse --short ${TRAVIS_COMMIT})
+  - secure: R2rTEfMHG3CHfbFBiSin6QI7hOm97DAIRz5bX0/My/jSuxGxblTbw3XntqFhByjbCgoWQn9crUQ1bdTp8RRmNC4/bbsdaPsXhD9jKnL/aJ+bNkEuh2/akyGnKvH300c2ZyGm5q5eC5FA20ErX5c3+86Sy821ywa/iC11YaV5XzP6lyxuFTJWs3e7SK7kbL4seyNd2sD/8DYzEeCwKxpCI8bVz7ZQUazP2IpkIjcS9SBeLwPHKbS1f2je8b6XIOkQUvJzxs3jrWIH9HwakA8/M/CSFo+GUkkRtPDj3V+lg1IyOA3VPLMxAVqeoryLIS6ITR8Zti+MDrodLM0llwo2dQ3ZI1RYzYieGcAg0XCflcH0fmrJd1gPiCuYKSmL48mAvgUkCThNU8nFekaqLLsspv7pS7+Ozi7f/j1pq8j4PkV2TV8HUa9RBcOepdeQnKxuFxc55NXfGvDPvqf9jw6CGxWqtFwRQg42gZtVWILgTvhmPchaIj0TKGYnnxG1jXXK0CQcMGOhF/T7WMrfZ1ZPVkT3/GUvh+PC7m2DE+dXonM1Ebo0p3lgWYlrlGv7fgjcrdHYi7FvqG0lZtUuNphGeoU7+QYOwZ0o7p7tboK24YW0dv7jybiCIzOloAfGgX+YflRZY9WpYJWMa0C9LaXok64oRT4/Fu0TEABHltc+TaY=
+  - secure: YK54XEeT5p/vCRG56GigVYAPVOEbqvHvltitS8JuhKw0jomYeB6FZf8N6ELZcbJh3pclwa9irihCGUxEbUKYaepQLBuns+c+EFKeEApFRdCUaZ/psKtg1A5gx+5MB4Qz5/ZA/CdyDYe3Muf0OAgkzfZxG9ayPtdanaOVCHyrY8jJDRCkgWqqOhnD1pw9MxhQpBUdtbOhdzb+F/mZ0P3be6+49BuFHcaPR3Ppw+3sUSy7ABoAWebjSk//FruEAPUel2WbivHo4GzJZydy4RqQG0YYkif2cz2h9I84uxLwXyl27dKd7oUvUtLaE1oQpYshoDGlCiO4VWUNDdMrrf3eBzkJ0QqF/wNF9CyYN1WIigK+gJ8vusPqB3V3f90RMdw6Q8vSLin0hcVpCTmDNXKlYmRJ5qzqWoyn7kX0vW4qCwCxiaL+iJg+Lu1ftIoWOY5oFmR6hkQjsIxrUqrTa2DA/SFU2Sde9E3Kx0q7l7BGJEcscmmyjrCJfFFaZX3jjY2So+xjgr0ymVO5KTG6PV8PZavsOG9TEXs8dl/9Bw8aup4rna8zixqp0nPJbQR9fLS9oub4eUpOIjl8fM3mbC7gAxr6zvQJ8yUdsBpjGiRHIWRzY2bAIDDSyqVo6uwlkeIlbXAakEgBFt6gcALvlOPV3YW6+rHps0hq6s4YYYXdhrE=
+  - secure: Ay+VkQA2gipR88zavvQ28IdrUFv5MQ9HSnIUxbt3iqjc1Qx2rmpRvC44L07LoU3gYzxeu5iyzp5qVjKgcuGeqTKZCJDCUI/iX0LyJZoZoZSnMRdNLblVie/Wt7kTn/jax5vdDR40+DJLDYBrTl9t+/Maut++gEJfeqbjYcIrS1GRC4XtQfgADu6yV5X4FwjaGRu6Ws6U3OAl4Obh9IsfGiB7ildpVGryXj2B348dneANCDT1JUpeWNJtGszr3HKSqgJFhAmDWYSoHluPZhMd1XofS18rNM3/YCQ+p078o4GGml9QPYAt5voMiJXYvOZl1FEehPPdDbEV0rpc12BLK8cq2a4uxWLYfE7SmQODHU2MtsBvqCNp7jEk4K00ub+B27Y4i45MSP6qWf4pZaACjg2RIDbGMIrSfZpxRodYFO6QgwobxS6kPrJQzBJJPjk82MIkvzxG1sw4BxAJBy+IctUlwLdeopXM+rUpjvfGy4Bv9QNHbma+3DA8SIL/hvHsdnKiFxVGgh7tdoWDSpKqENZptWUcPMx5OsnDT8cv4TcMiEVX5+Ya+rQYUB9qVfG34QOSnTCaCGrUIarfMSWNnFhNWDv6AqTPF3rlLxASPJ17OOnD0VMm+IfGLE6Kv7MBi99dXAqHHu1OgLbJhzCA3Wqtflkv8hZzn9CpANJbMgI=
+  - secure: eFF6Eyz3nluIT0nW0Dx0cCY5ho88CNZyxv8hXUUSTzuyDSfAIaPPIyTjgCNcoMxLWjEyR1NuNywcWUv50tJBeTv8U5jJSkP4SmZtMIqoFGEobOUuQ06eHPtdMhxZSjmgWbnET45AAG+lUBIwfWndItukaxGMOtuS6Lv4pjCNZeLXhLEJPeJ6OEsE1ZerqZojAFlv0Jge7D8RyVdx1pfHec85vBbpS9kfM/McntHRVDJuVsKjvIE1ExzL3L/wK4ouJxdC20rYdZv6q6zTEjbAVZWn3kDJy7jL+warL1eTv/YZda1+1TVSKFwZNgjmtV2CLIdpSlJIGmP4N3Svp/2wF+vMCEhOHB/KgiaPjefcjPT0CUOAEExoXaF2mccZysPazk8qvoQ3DU7o6BuXu/sIC5o/5qYzhlm/Ir/3xgWHsM5m7hTyol+emtt1Nhh+EGpAORIAfb6+g2acqYfgp4HsR14VPblYwd33PG3hF3aGqa5eKhX9lwYNZr98S6VyVu/1vRNyBpes8lcaVCKzQd6s5urmHQQge8HKESuJdNuLBn2m4F8/6TWgTwxywiMKezOwRVnKciJffMqkoXXmwuPEt+aHJyQp6e7zlo0pFxohNCiyxr/9Us6tXrXX6sIFVOc9uwBDYr53pRA5n3tUrJDeuLWCIGSQdB7G2ZUkI3+jtOI=
 cache:
   directories:
-    - build-cache
-
+  - build-cache
 install:
-  - docker-compose -f docker-compose.yml build
-
+- docker-compose -f docker-compose.yml build
 script:
-  - docker-compose -f docker-compose.yml run ${SERVICE_NAME}
-
+- docker-compose -f docker-compose.yml run ${SERVICE_NAME}
 before_cache:
-  - docker-compose -f docker-compose.yml run --rm -v `pwd`/build-cache:/app/build-cache ${SERVICE_NAME} bash docker-utils.sh save-cache
+- docker-compose -f docker-compose.yml run --rm -v `pwd`/build-cache:/app/build-cache
+  ${SERVICE_NAME} bash docker-utils.sh save-cache

README.md

@@ -5,7 +5,7 @@ Follow [@AsyncHttpClient](https://twitter.com/AsyncHttpClient) on Twitter.
 The AsyncHttpClient (AHC) library allows Java applications to easily execute HTTP requests and asynchronously process HTTP responses.
 The library also supports the WebSocket Protocol.
 
-It's built on top of [Netty](https://github.com/netty/netty). I's currently compiled on Java 8 but runs on Java 9 too.
+It's built on top of [Netty](https://github.com/netty/netty). It's currently compiled on Java 8 but runs on Java 9 too.
 
 ## Installation
 
@@ -110,6 +110,7 @@ Use the `addBodyPart` method to add a multipart part to the request.
 This part can be of type:
 * `ByteArrayPart`
 * `FilePart`
+* `InputStreamPart`
 * `StringPart`
 
 ### Dealing with Responses
@@ -158,7 +159,7 @@ See `AsyncCompletionHandler` implementation as an example.
 
 The below sample just capture the response status and skips processing the response body chunks.
 
-Note that returning `ABORT` closed the underlying connection.
+Note that returning `ABORT` closes the underlying connection.
 
 ```java
 import static org.asynchttpclient.Dsl.*;
@@ -195,7 +196,7 @@ Integer statusCode = whenStatusCode.get();
 
 #### Using Continuations
 
-`ListenableFuture` has a `toCompletableFuture` that returns a `CompletableFuture`.
+`ListenableFuture` has a `toCompletableFuture` method that returns a `CompletableFuture`.
 Beware that canceling this `CompletableFuture` won't properly cancel the ongoing request.
 There's a very good chance we'll return a `CompletionStage` instead in the next release.
 
@@ -243,7 +244,7 @@ WebSocket websocket = c.prepareGet("ws://demos.kaazing.com/echo")
 
 ## Reactive Streams
 
-AsyncHttpClient has build in support for reactive streams.
+AsyncHttpClient has built-in support for reactive streams.
 
 You can pass a request body as a `Publisher<ByteBuf>` or a `ReactiveStreamsBodyGenerator`.
 
@@ -288,7 +289,7 @@ Keep up to date on the library development by joining the Asynchronous HTTP Clie
 
 Of course, Pull Requests are welcome.
 
-Here a the few rules we'd like you to respect if you do so:
+Here are the few rules we'd like you to respect if you do so:
 
 * Only edit the code related to the suggested change, so DON'T automatically format the classes you've edited.
 * Use IntelliJ default formatting rules.

client/pom.xml

@@ -73,5 +73,10 @@
       <artifactId>reactive-streams-examples</artifactId>
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>org.apache.kerby</groupId>
+      <artifactId>kerb-simplekdc</artifactId>
+      <scope>test</scope>
+    </dependency>
   </dependencies>
 </project>

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

@@ -24,7 +24,7 @@
 /**
  * An {@link AsyncHandler} augmented with an {@link #onCompleted(Response)}
  * convenience method which gets called when the {@link Response} processing is
- * finished. This class also implement the {@link ProgressAsyncHandler}
+ * finished. This class also implements the {@link ProgressAsyncHandler}
  * callback, all doing nothing except returning
  * {@link org.asynchttpclient.AsyncHandler.State#CONTINUE}
  *

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

@@ -19,6 +19,7 @@
 import io.netty.handler.codec.http.HttpHeaders;
 import org.asynchttpclient.netty.request.NettyRequest;
 
+import javax.net.ssl.SSLSession;
 import java.net.InetSocketAddress;
 import java.util.List;
 
@@ -37,9 +38,9 @@
  * </ol>
  * <br>
  * Returning a {@link AsyncHandler.State#ABORT} from any of those callback methods will interrupt asynchronous response
- * processing, after that only {@link #onCompleted()} is going to be called.
+ * processing. After that, only {@link #onCompleted()} is going to be called.
  * <br>
- * AsyncHandler aren't thread safe, hence you should avoid re-using the same instance when doing concurrent requests.
+ * AsyncHandlers aren't thread safe. Hence, you should avoid re-using the same instance when doing concurrent requests.
  * As an example, the following may produce unexpected results:
  * <blockquote><pre>
  *   AsyncHandler ah = new AsyncHandler() {....};
@@ -49,9 +50,10 @@
  * </pre></blockquote>
  * It is recommended to create a new instance instead.
  * <p>
- * Do NOT perform any blocking operation in there, typically trying to send another request and call get() on its future.
+ * Do NOT perform any blocking operations in any of these methods. A typical example would be trying to send another
+ * request and calling get() on its future.
  * There's a chance you might end up in a dead lock.
- * If you really to perform blocking operation, executed it in a different dedicated thread pool.
+ * If you really need to perform a blocking operation, execute it in a different dedicated thread pool.
  *
  * @param <T> Type of object returned by the {@link java.util.concurrent.Future#get}
  */
@@ -142,6 +144,8 @@ default void onHostnameResolutionSuccess(String name, List<InetSocketAddress> ad
   default void onHostnameResolutionFailure(String name, Throwable cause) {
   }
 
+  // ////////////// TCP CONNECT ////////
+
   /**
    * Notify the callback when trying to open a new connection.
    * <p>
@@ -152,8 +156,6 @@ default void onHostnameResolutionFailure(String name, Throwable cause) {
   default void onTcpConnectAttempt(InetSocketAddress remoteAddress) {
   }
 
-  // ////////////// TCP CONNECT ////////
-
   /**
    * Notify the callback after a successful connect
    *
@@ -174,18 +176,18 @@ default void onTcpConnectSuccess(InetSocketAddress remoteAddress, Channel connec
   default void onTcpConnectFailure(InetSocketAddress remoteAddress, Throwable cause) {
   }
 
+  // ////////////// TLS ///////////////
+
   /**
    * Notify the callback before TLS handshake
    */
   default void onTlsHandshakeAttempt() {
   }
 
-  // ////////////// TLS ///////////////
-
   /**
    * Notify the callback after the TLS was successful
    */
-  default void onTlsHandshakeSuccess() {
+  default void onTlsHandshakeSuccess(SSLSession sslSession) {
   }
 
   /**
@@ -196,14 +198,14 @@ default void onTlsHandshakeSuccess() {
   default void onTlsHandshakeFailure(Throwable cause) {
   }
 
+  // /////////// POOLING /////////////
+
   /**
    * Notify the callback when trying to fetch a connection from the pool.
    */
   default void onConnectionPoolAttempt() {
   }
 
-  // /////////// POOLING /////////////
-
   /**
    * Notify the callback when a new connection was successfully fetched from the pool.
    *
@@ -220,6 +222,8 @@ default void onConnectionPooled(Channel connection) {
   default void onConnectionOffer(Channel connection) {
   }
 
+  // //////////// SENDING //////////////
+
   /**
    * Notify the callback when a request is being written on the channel. If the original request causes multiple requests to be sent, for example, because of authorization or
    * retry, it will be notified multiple times.
@@ -229,8 +233,6 @@ default void onConnectionOffer(Channel connection) {
   default void onRequestSend(NettyRequest request) {
   }
 
-  // //////////// SENDING //////////////
-
   /**
    * Notify the callback every time a request is being retried.
    */

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

@@ -21,15 +21,15 @@
 import java.util.function.Predicate;
 
 /**
- * This class support asynchronous and synchronous HTTP request.
+ * This class support asynchronous and synchronous HTTP requests.
  * <br>
- * To execute synchronous HTTP request, you just need to do
+ * To execute a synchronous HTTP request, you just need to do
  * <blockquote><pre>
  *    AsyncHttpClient c = new AsyncHttpClient();
  *    Future&lt;Response&gt; f = c.prepareGet(TARGET_URL).execute();
  * </pre></blockquote>
  * <br>
- * The code above will block until the response is fully received. To execute asynchronous HTTP request, you
+ * The code above will block until the response is fully received. To execute an asynchronous HTTP request, you
  * create an {@link AsyncHandler} or its abstract implementation, {@link AsyncCompletionHandler}
  * <br>
  * <blockquote><pre>
@@ -48,7 +48,7 @@
  *      &#125;);
  *      Response response = f.get();
  *
- *      // We are just interested to retrieve the status code.
+ *      // We are just interested in retrieving the status code.
  *     Future&lt;Integer&gt; f = c.prepareGet(TARGET_URL).execute(new AsyncCompletionHandler&lt;Integer&gt;() &#123;
  *
  *          &#64;Override
@@ -63,10 +63,10 @@
  *      &#125;);
  *      Integer statusCode = f.get();
  * </pre></blockquote>
- * The {@link AsyncCompletionHandler#onCompleted(Response)} will be invoked once the http response has been fully read, which include
- * the http headers and the response body. Note that the entire response will be buffered in memory.
+ * The {@link AsyncCompletionHandler#onCompleted(Response)} method will be invoked once the http response has been fully read.
+ * The {@link Response} object includes the http headers and the response body. Note that the entire response will be buffered in memory.
  * <br>
- * You can also have more control about the how the response is asynchronously processed by using a {@link AsyncHandler}
+ * You can also have more control about the how the response is asynchronously processed by using an {@link AsyncHandler}
  * <blockquote><pre>
  *      AsyncHttpClient c = new AsyncHttpClient();
  *      Future&lt;String&gt; f = c.prepareGet(TARGET_URL).execute(new AsyncHandler&lt;String&gt;() &#123;
@@ -106,8 +106,8 @@
  *
  *      String bodyResponse = f.get();
  * </pre></blockquote>
- * You can asynchronously process the response status,headers and body and decide when to
- * stop the processing the response by returning a new {@link AsyncHandler.State#ABORT} at any moment.
+ * You can asynchronously process the response status, headers and body and decide when to
+ * stop processing the response by returning a new {@link AsyncHandler.State#ABORT} at any moment.
  *
  * This class can also be used without the need of {@link AsyncHandler}.
  * <br>
@@ -125,8 +125,8 @@
  *      Response r = f.get();
  * </pre></blockquote>
  * <br>
- * An instance of this class will cache every HTTP 1.1 connections and close them when the {@link DefaultAsyncHttpClientConfig#getReadTimeout()}
- * expires. This object can hold many persistent connections to different host.
+ * An instance of this class will cache every HTTP 1.1 connection and close them when the {@link DefaultAsyncHttpClientConfig#getReadTimeout()}
+ * expires. This object can hold many persistent connections to different hosts.
  */
 public interface AsyncHttpClient extends Closeable {
 
@@ -138,7 +138,7 @@ public interface AsyncHttpClient extends Closeable {
   boolean isClosed();
 
   /**
-   * Set default signature calculator to use for requests build by this client instance
+   * Set default signature calculator to use for requests built by this client instance
    *
    * @param signatureCalculator a signature calculator
    * @return {@link RequestBuilder}

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

@@ -65,6 +65,14 @@ public interface AsyncHttpClientConfig {
    */
   int getMaxConnectionsPerHost();
 
+  /**
+   * Return the maximum duration in milliseconds an {@link AsyncHttpClient} can wait to acquire a free channel
+   *
+   * @return Return the maximum duration in milliseconds an {@link AsyncHttpClient} can wait to acquire a free channel
+   */
+  int getAcquireFreeChannelTimeout();
+
+
   /**
    * Return the maximum time in millisecond an {@link AsyncHttpClient} can wait when connecting to a remote host
    *