Don't ignore empty SSE events in client

RESTEasy Classic does not ignore them, so let's keep the same behavior Closes: quarkusio#35966 (cherry picked from commit a3ba466)
aloubyansky · Oct 31, 2023 · 8449c98 · 8449c98
1 parent 154fe51
commit 8449c98
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 20 deletions.
diff --git a/...t/src/test/java/io/quarkus/resteasy/reactive/jsonb/deployment/test/sse/SseParserTest.java b/...t/src/test/java/io/quarkus/resteasy/reactive/jsonb/deployment/test/sse/SseParserTest.java
@@ -140,23 +140,12 @@ public void testParser() {
     }
 
     private void testParser(String event, String data, String comment, String lastId, String name, long reconnectDelay) {
-        if (data != null) {
-            testParser(Collections.singletonList(event), Collections.singletonList(new InboundSseEventImpl(null, null)
-                    .setData(data)
-                    .setComment(comment)
-                    .setId(lastId)
-                    .setName(name)
-                    .setReconnectDelay(reconnectDelay)));
-        } else if (comment != null) {
-            testParser(Collections.singletonList(event), Collections.singletonList(new InboundSseEventImpl(null, null)
-                    .setData(null)
-                    .setComment(comment)
-                    .setId(lastId)
-                    .setName(name)
-                    .setReconnectDelay(reconnectDelay)));
-        } else {
-            testParser(Collections.singletonList(event), Collections.emptyList());
-        }
+        testParser(Collections.singletonList(event), Collections.singletonList(new InboundSseEventImpl(null, null)
+                .setData(data)
+                .setComment(comment)
+                .setId(lastId)
+                .setName(name)
+                .setReconnectDelay(reconnectDelay)));
     }
 
     private void testParser(List<String> events, List<InboundSseEvent> expectedEvents) {

diff --git a/...ctive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/SseParser.java b/...ctive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/SseParser.java
@@ -144,9 +144,6 @@ private void parseEvent() {
     }
 
     private void dispatchEvent() {
-        // ignore empty events
-        if (dataBuffer.length() == 0 && commentBuffer.length() == 0)
-            return;
         WebTargetImpl webTarget = sseEventSource.getWebTarget();
         InboundSseEventImpl event;
         // tests don't set a web target, and we don't want them to end up starting vertx just to test parsing