#63 - Add support for HttpResponse.BodyHandler with and without generic parameters

Author: rbygrave

http-generator-client/src/main/java/io/avaje/http/generator/client/ClientMethodWriter.java

@@ -61,6 +61,7 @@ private void methodStart(Append writer) {
    */
   private void checkBodyHandler(MethodParam param) {
     if (param.getRawType().startsWith(BODY_HANDLER)) {
+      param.setResponseHandler();
       bodyHandlerParam = param;
       methodGenericParams = param.getUType().genericParams();
     }

http-generator-core/src/main/java/io/avaje/http/generator/core/ElementReader.java

@@ -8,6 +8,8 @@
 import javax.lang.model.element.TypeElement;
 import javax.validation.Valid;
 
+import static io.avaje.http.generator.core.ParamType.RESPONSE_HANDLER;
+
 public class ElementReader {
 
   private final ProcessingContext ctx;
@@ -310,4 +312,8 @@ public UType getType() {
   public Element getElement() {
     return element;
   }
+
+  public void setResponseHandler() {
+    paramType = RESPONSE_HANDLER;
+  }
 }

http-generator-core/src/main/java/io/avaje/http/generator/core/MethodParam.java

@@ -63,4 +63,8 @@ public ParamType getParamType() {
   public UType getUType() {
     return elementParam.getType();
   }
+
+  public void setResponseHandler() {
+    elementParam.setResponseHandler();
+  }
 }

http-generator-core/src/main/java/io/avaje/http/generator/core/ParamType.java

@@ -10,7 +10,8 @@ public enum ParamType {
   QUERYPARAM("queryParam", "query"),
   FORMPARAM("formParam", "form"),
   COOKIE("cookie", "cookie"),
-  HEADER("header", "header");
+  HEADER("header", "header"),
+  RESPONSE_HANDLER("notUsed", "notUsed");
 
   private final String code;
   private final String type;

tests/test-client/src/main/java/org/example/JunkApi.java

@@ -6,6 +6,7 @@
 import io.avaje.http.client.HttpCall;
 
 import java.io.InputStream;
+import java.net.http.HttpRequest;
 import java.net.http.HttpResponse;
 import java.nio.file.Path;
 import java.util.List;
@@ -41,13 +42,24 @@ public interface JunkApi {
 
   @Post
   Repo bean();
-
   @Post
   List<Repo> list();
-
   @Post
   Stream<Repo> stream();
 
+  @Post
+  CompletableFuture<Repo> cfBean();
+  @Post
+  CompletableFuture<List<Repo>> cfList();
+  @Post
+  CompletableFuture<Stream<Repo>> cfStream();
+
+  @Post
+  HttpCall<Repo> callBean();
+  @Post
+  HttpCall<List<Repo>> callList();
+  @Post
+  HttpCall<Stream<Repo>> callStream();
   // -------
 
   // @Post CompletableFuture<Void> cfVoidErr();
@@ -108,4 +120,7 @@ public interface JunkApi {
   @Get
   HttpCall<HttpResponse<Path>> callWithHandPath(HttpResponse.BodyHandler<Path> handler);
 
+  @Post("/{id}/foo/{name}")
+  HttpResponse<Path> reqBodyResHand2(HttpResponse.BodyHandler<Path> handler, HttpRequest.BodyPublisher body, String id, String name, String other);
+
 }