(camel) 02/02: (chores) camel-atmosphere-websocket: simplify stream copies

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git

commit d3bc8960a8170ff9f46b0abfdc55982c4f5580f1
Author: Otavio R. Piske <angusyo...@gmail.com>
AuthorDate: Sun Feb 2 13:06:58 2025 +0100

    (chores) camel-atmosphere-websocket: simplify stream copies
---
 .../atmosphere/websocket/WebsocketRouteTest.java   | 28 ++++++----------------
 1 file changed, 7 insertions(+), 21 deletions(-)

diff --git 
a/components/camel-atmosphere-websocket/src/test/java/org/apache/camel/component/atmosphere/websocket/WebsocketRouteTest.java
 
b/components/camel-atmosphere-websocket/src/test/java/org/apache/camel/component/atmosphere/websocket/WebsocketRouteTest.java
index 6c1b4366ba3..85c718da08e 100644
--- 
a/components/camel-atmosphere-websocket/src/test/java/org/apache/camel/component/atmosphere/websocket/WebsocketRouteTest.java
+++ 
b/components/camel-atmosphere-websocket/src/test/java/org/apache/camel/component/atmosphere/websocket/WebsocketRouteTest.java
@@ -27,6 +27,7 @@ import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.test.infra.common.http.WebsocketTestClient;
+import org.apache.camel.util.IOHelper;
 import org.junit.jupiter.api.Test;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -204,34 +205,19 @@ public class WebsocketRouteTest extends 
WebsocketCamelRouterTestSupport {
     }
 
     private static String readAll(Reader reader) {
-        StringBuilder builder = new StringBuilder();
         try {
-            char[] buf = new char[4024];
-            int n;
-            while ((n = reader.read(buf, 0, buf.length)) > 0) {
-                builder.append(buf, 0, n);
-            }
+            return IOHelper.toString(reader);
         } catch (IOException e) {
-            // ignore
-        } finally {
-            try {
-                reader.close();
-            } catch (IOException e) {
-                // ignore
-            }
         }
 
-        return builder.toString();
+        return "";
     }
 
     private static byte[] readAll(InputStream is) {
-        ByteArrayOutputStream bytebuf = new ByteArrayOutputStream();
+        ByteArrayOutputStream byteBuf = new ByteArrayOutputStream();
+
         try {
-            byte[] buf = new byte[4024];
-            int n;
-            while ((n = is.read(buf, 0, buf.length)) > 0) {
-                bytebuf.write(buf, 0, n);
-            }
+            is.transferTo(byteBuf);
         } catch (IOException e) {
             // ignore
         } finally {
@@ -242,7 +228,7 @@ public class WebsocketRouteTest extends 
WebsocketCamelRouterTestSupport {
             }
         }
 
-        return bytebuf.toByteArray();
+        return byteBuf.toByteArray();
     }
     // END SNIPPET: payload
 }