Resteasy Reactive: Fix line separator for "x-ndjson" and "stream+json".

We're wrongly using `/n` instead of `\n`. This was done in quarkusio#20908
Sgitario · Mar 9, 2022 · a619566 · a619566
1 parent 07cc8d4
commit a619566
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 9 deletions.
diff --git a/...t/src/test/java/io/quarkus/resteasy/reactive/jackson/deployment/test/sse/SseTestCase.java b/...t/src/test/java/io/quarkus/resteasy/reactive/jackson/deployment/test/sse/SseTestCase.java
@@ -119,8 +119,8 @@ public void testNdJsonMultiFromMulti() {
         when().get(uri.toString() + "sse/ndjson/multi")
                 .then().statusCode(HttpStatus.SC_OK)
                 // @formatter:off
-                .body(is("{\"name\":\"hello\"}/n"
-                            + "{\"name\":\"stef\"}/n"))
+                .body(is("{\"name\":\"hello\"}\n"
+                            + "{\"name\":\"stef\"}\n"))
                 // @formatter:on
                 .header(HttpHeaders.CONTENT_TYPE, containsString(RestMediaType.APPLICATION_NDJSON));
     }
@@ -130,8 +130,8 @@ public void testStreamJsonMultiFromMulti() {
         when().get(uri.toString() + "sse/stream-json/multi")
                 .then().statusCode(HttpStatus.SC_OK)
                 // @formatter:off
-                .body(is("{\"name\":\"hello\"}/n"
-                        + "{\"name\":\"stef\"}/n"))
+                .body(is("{\"name\":\"hello\"}\n"
+                        + "{\"name\":\"stef\"}\n"))
                 // @formatter:on
                 .header(HttpHeaders.CONTENT_TYPE, containsString(RestMediaType.APPLICATION_STREAM_JSON));
     }

diff --git a/...ent/src/test/java/io/quarkus/resteasy/reactive/jsonb/deployment/test/sse/SseTestCase.java b/...ent/src/test/java/io/quarkus/resteasy/reactive/jsonb/deployment/test/sse/SseTestCase.java
@@ -117,8 +117,8 @@ public void testNdJsonMultiFromMulti() {
         when().get(uri.toString() + "sse/ndjson/multi")
                 .then().statusCode(HttpStatus.SC_OK)
                 // @formatter:off
-                .body(is("{\"name\":\"hello\"}/n"
-                            + "{\"name\":\"stef\"}/n"))
+                .body(is("{\"name\":\"hello\"}\n"
+                            + "{\"name\":\"stef\"}\n"))
                 // @formatter:on
                 .header(HttpHeaders.CONTENT_TYPE, containsString(RestMediaType.APPLICATION_NDJSON));
     }
@@ -128,8 +128,8 @@ public void testStreamJsonMultiFromMulti() {
         when().get(uri.toString() + "sse/stream-json/multi")
                 .then().statusCode(HttpStatus.SC_OK)
                 // @formatter:off
-                .body(is("{\"name\":\"hello\"}/n"
-                        + "{\"name\":\"stef\"}/n"))
+                .body(is("{\"name\":\"hello\"}\n"
+                        + "{\"name\":\"stef\"}\n"))
                 // @formatter:on
                 .header(HttpHeaders.CONTENT_TYPE, containsString(RestMediaType.APPLICATION_STREAM_JSON));
     }

diff --git a/...e/src/main/java/org/jboss/resteasy/reactive/server/handlers/PublisherResponseHandler.java b/...e/src/main/java/org/jboss/resteasy/reactive/server/handlers/PublisherResponseHandler.java
@@ -66,7 +66,7 @@ public void accept(Object v, Throwable t) {
 
     private static class ChunkedStreamingMultiSubscriber extends StreamingMultiSubscriber {
 
-        private static final String LINE_SEPARATOR = "/n";
+        private static final String LINE_SEPARATOR = "\n";
 
         private boolean isFirstItem = true;