Optimized(undertow): process requests optimizations cutting allocations and response body writes NIO

experimental/camunda-rest-undertow/src/main/java/io/koraframework/camunda/rest/undertow/UndertowCamundaRestHttpHandler.java

@@ -11,7 +11,7 @@
 import io.koraframework.common.util.TimeUtils;
 import io.koraframework.http.server.undertow.handler.KoraRequestProcessingHttpHandler;
 import io.koraframework.http.server.undertow.UndertowContext;
-import io.koraframework.http.server.undertow.handler.KoraVirtualThreadDispatchHttpHandler;
+import io.koraframework.http.server.undertow.handler.KoraVirtualThreadPerConnectionDispatchHttpHandler;
 import io.opentelemetry.api.trace.propagation.W3CTraceContextPropagator;
 import io.undertow.server.HttpHandler;
 import io.undertow.server.handlers.PathHandler;
@@ -147,7 +147,7 @@ public void init() throws Exception {
         });
 
         root.addPrefixPath("/", new OpenApiHttpHandler(camundaRestConfig));
-        this.realhttpHandler = new KoraVirtualThreadDispatchHttpHandler("camunda-rest", root);
+        this.realhttpHandler = new KoraVirtualThreadPerConnectionDispatchHttpHandler("camunda-rest", root);
 
         logger.info("Camunda Rest Handler (Undertow) configured in {}", TimeUtils.tookForLogging(started));
     }

http/http-client-common/src/main/java/io/koraframework/http/client/common/request/mapper/HttpClientRequestMapperModule.java

@@ -1,10 +1,11 @@
 package io.koraframework.http.client.common.request.mapper;
 
 import io.koraframework.common.annotation.DefaultComponent;
-import io.koraframework.common.annotation.Tag;
 import io.koraframework.http.client.common.request.HttpClientRequestMapper;
 import io.koraframework.http.common.body.HttpBody;
 import io.koraframework.http.common.body.HttpBodyOutput;
+import io.koraframework.http.common.form.FormMultipart;
+import io.koraframework.http.common.form.FormUrlEncoded;
 import io.koraframework.json.common.JsonWriter;
 import io.koraframework.json.common.annotation.Json;
 
@@ -33,18 +34,18 @@ default HttpClientRequestMapper<String> httpClientRequestStringMapper() {
     }
 
     @DefaultComponent
-    default FormUrlEncodedClientRequestMapper httpClientRequestFormUrlEncodedMapper() {
+    default HttpClientRequestMapper<FormUrlEncoded> httpClientRequestFormUrlEncodedMapper() {
         return new FormUrlEncodedClientRequestMapper();
     }
 
     @DefaultComponent
-    default FormMultipartClientRequestMapper httpClientRequestFormMultipartMapper() {
+    default HttpClientRequestMapper<FormMultipart> httpClientRequestFormMultipartMapper() {
         return new FormMultipartClientRequestMapper();
     }
 
     @Json
     @DefaultComponent
-    default <T> JsonHttpClientRequestMapper<T> httpClientRequestJsonMapper(JsonWriter<T> writer) {
+    default <T> HttpClientRequestMapper<T> httpClientRequestJsonMapper(JsonWriter<T> writer) {
         return new JsonHttpClientRequestMapper<>(writer);
     }
 }

http/http-common/src/main/java/io/koraframework/http/common/body/DefaultFullHttpBody.java

@@ -43,7 +43,7 @@ public void write(OutputStream os) throws IOException {
             data = data.slice();
             while (data.hasRemaining()) {
                 var len = Math.min(data.remaining(), buf.length);
-                data.get(buf);
+                data.get(buf, 0, len);
                 os.write(buf, 0, len);
             }
         }

http/http-common/src/main/java/io/koraframework/http/common/body/JsonHttpBodyOutput.java

@@ -1,8 +1,8 @@
 package io.koraframework.http.common.body;
 
-import org.jspecify.annotations.Nullable;
 import io.koraframework.json.common.JsonModule;
 import io.koraframework.json.common.JsonWriter;
+import org.jspecify.annotations.Nullable;
 import tools.jackson.core.JsonEncoding;
 import tools.jackson.core.ObjectWriteContext;