IO simplification (#11)

* IO simplification

* Avoid unnecessary wrapping with a reader

---------

Co-authored-by: scrhartley <scrhartley@github.com>

Author: scrhartley

core/src/main/java/starfederation/datastar/utils/SignalReader.java

@@ -4,8 +4,10 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import starfederation.datastar.adapters.request.RequestAdapter;
 
-import java.io.BufferedReader;
 import java.io.IOException;
+import java.io.Reader;
+import java.io.StringWriter;
+import java.io.Writer;
 import java.util.Map;
 import java.util.Objects;
 import java.util.concurrent.ConcurrentMap;
@@ -37,15 +39,10 @@ public static void readSignals(RequestAdapter requestAdapter, ConcurrentMap<Stri
             }
         } else {
             // Handle other methods by reading the request body
-            StringBuilder requestBody = new StringBuilder();
-            try (BufferedReader reader = requestAdapter.getReader()) {
-                String line;
-                while ((line = reader.readLine()) != null) {
-                    requestBody.append(line);
-                }
+            try (Reader reader = requestAdapter.getReader(); Writer writer = new StringWriter()) {
+                reader.transferTo(writer);
+                data = writer.toString();
             }
-
-            data = requestBody.toString();
             if (data.isEmpty()) {
                 throw new IllegalArgumentException("Request body cannot be empty.");
             }

examples/hello-world/src/main/java/org/example/servlets/HtmlServlet.java

@@ -21,12 +21,8 @@ protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws IO
 
         resp.setContentType("text/html;charset=UTF-8");
 
-        try (BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
-             PrintWriter writer = resp.getWriter()) {
-            String line;
-            while ((line = reader.readLine()) != null) {
-                writer.println(line);
-            }
+        try (inputStream; OutputStream output = resp.getOutputStream()) {
+            inputStream.transferTo(output);
         }
     }
 }