support inputstream

Author: SentryMan

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

@@ -33,9 +33,9 @@ public static Map<String, UType> jsonTypes(ControllerReader reader) {
             methodReader -> {
               addJsonBodyType(methodReader, addToMap);
               if (!methodReader.isVoid()) {
-                UType uType = UType.parse(methodReader.returnType());
+                var uType = UType.parse(methodReader.returnType());
 
-                if (uType.mainType().equals("java.util.concurrent.CompletableFuture")) {
+                if ("java.util.concurrent.CompletableFuture".equals(uType.mainType())) {
                   uType = uType.paramRaw();
                 }
 
@@ -51,6 +51,8 @@ private static void addJsonBodyType(MethodReader methodReader, Consumer<UType> a
       methodReader.params().stream()
           .filter(MethodParam::isBody)
           .map(MethodParam::utype)
+          .filter(s -> !s.full().startsWith("java.io.InputStream"))
+          .filter(s -> !s.full().startsWith("byte[]"))
           .forEach(addToMap);
     }
   }

http-generator-javalin/src/main/java/io/avaje/http/generator/javalin/JavalinAdapter.java

@@ -31,10 +31,16 @@ public boolean isBodyMethodParam() {
 
   @Override
   public String bodyAsClass(UType type) {
-    if (useJsonB) {
-      return type.shortName() + "JsonType.fromJson(ctx.bodyInputStream())";
+    if (type.full().startsWith("java.io.InputStream")) {
+      return "ctx.bodyInputStream()";
+    } else if (type.full().startsWith("byte[]")) {
+      return "ctx.bodyAsBytes()";
+    } else {
+      if (useJsonB) {
+        return type.shortName() + "JsonType.fromJson(ctx.bodyInputStream())";
+      }
+      return "ctx.bodyAsClass(" + type.mainType() + ".class)";
     }
-    return "ctx.bodyAsClass(" + type.mainType() + ".class)";
   }
 
   @Override