Add Async list() of beans support

Author: rbygrave

client/src/main/java/io/avaje/http/client/DHttpAsync.java

@@ -1,6 +1,7 @@
 package io.avaje.http.client;
 
 import java.net.http.HttpResponse;
+import java.util.List;
 import java.util.concurrent.CompletableFuture;
 
 class DHttpAsync implements HttpAsyncResponse {
@@ -31,4 +32,11 @@ public <E> CompletableFuture<E> bean(Class<E> type) {
       .performSendAsync(true, HttpResponse.BodyHandlers.ofByteArray())
       .thenApply(httpResponse -> request.asyncBean(type, httpResponse));
   }
+
+  @Override
+  public <E> CompletableFuture<List<E>> list(Class<E> type) {
+    return request
+      .performSendAsync(true, HttpResponse.BodyHandlers.ofByteArray())
+      .thenApply(httpResponse -> request.asyncList(type, httpResponse));
+  }
 }

client/src/main/java/io/avaje/http/client/DHttpClientRequest.java

@@ -394,15 +394,24 @@ protected <T> CompletableFuture<HttpResponse<T>> performSendAsync(boolean loggab
   }
 
   protected <E> E asyncBean(Class<E> type, HttpResponse<byte[]> response) {
+    afterAsyncEncoded(response);
+    return context.readBean(type, encodedResponseBody);
+  }
+
+  protected <E> List<E> asyncList(Class<E> type, HttpResponse<byte[]> response) {
+    afterAsyncEncoded(response);
+    return context.readList(type, encodedResponseBody);
+  }
+
+  private void afterAsyncEncoded(HttpResponse<byte[]> response) {
     requestTimeNanos = System.nanoTime() - startAsyncNanos;
     httpResponse = response;
     encodedResponseBody = context.readContent(response);
     context.afterResponse(this);
     context.checkMaybeThrow(response);
-    return context.readBean(type, encodedResponseBody);
   }
 
-  public <E> HttpResponse<E> afterAsync(HttpResponse<E> response) {
+  protected <E> HttpResponse<E> afterAsync(HttpResponse<E> response) {
     requestTimeNanos = System.nanoTime() - startAsyncNanos;
     httpResponse = response;
     context.afterResponse(this);

client/src/main/java/io/avaje/http/client/HttpAsyncResponse.java

@@ -1,6 +1,7 @@
 package io.avaje.http.client;
 
 import java.net.http.HttpResponse;
+import java.util.List;
 import java.util.concurrent.CompletableFuture;
 
 /**
@@ -81,11 +82,37 @@ public interface HttpAsyncResponse {
    *           // use helloDto
    *           ...
    *         }
-   *
    *       });
+   * }</pre>
+   */
+  <E> CompletableFuture<E> bean(Class<E> type);
+
+  /**
+   * Process expecting a list of beans response body (typically from json content).
+   * <p>
+   * If the HTTP statusCode is 300 or above a HttpException is throw which
+   * contains the HttpResponse.
+   *
+   * <pre>{@code
+   *
+   *    clientContext.request()
+   *       ...
+   *       .GET().async()
+   *       .list(HelloDto.class)
+   *       .whenComplete((helloDtos, throwable) -> {
    *
+   *         if (throwable != null) {
+   *           HttpException httpException = (HttpException) throwable.getCause();
+   *           int statusCode = httpException.getStatusCode();
+   *           ...
    *
+   *         } else {
+   *           // use list of helloDto
+   *           ...
+   *         }
+   *       });
    * }</pre>
    */
-  <E> CompletableFuture<E> bean(Class<E> type);
+  <E> CompletableFuture<List<E>> list(Class<E> type);
+
 }

client/src/test/java/io/avaje/http/client/HelloControllerTest.java

@@ -104,6 +104,27 @@ void get_hello_returningListOfBeans() {
     assertThat(helloDtos).hasSize(2);
   }
 
+  @Test
+  void async_list() throws ExecutionException, InterruptedException {
+
+    AtomicReference<List<HelloDto>> ref = new AtomicReference<>();
+
+    final CompletableFuture<List<HelloDto>> future = clientContext.request()
+      .path("hello")
+      .GET().async()
+      .list(HelloDto.class);
+
+    future.whenComplete((helloDtos, throwable) -> {
+      assertThat(throwable).isNull();
+      assertThat(helloDtos).hasSize(2);
+      ref.set(helloDtos);
+    });
+
+    final List<HelloDto> helloDtos = future.get();
+    assertThat(helloDtos).hasSize(2);
+    assertThat(helloDtos).isSameAs(ref.get());
+  }
+
   @Test
   void get_withPathParamAndQueryParam_returningBean() {