Merge pull request #36450 from geoand/sse-null

Don't emit null values from SSE
quarkusio · Oct 13, 2023 · 01240b9 · 01240b9
2 parents b2179b8 + d7911a1
commit 01240b9
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...ve/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/MultiInvoker.java b/...ve/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/MultiInvoker.java
@@ -163,7 +163,10 @@ private <R> void registerForSse(MultiRequest<? super R> multiRequest,
         sseSource.register(event -> {
             // DO NOT pass the response mime type because it's SSE: let the event pick between the X-SSE-Content-Type header or
             // the content-type SSE field
-            multiRequest.emit(event.readData(responseType));
+            R item = event.readData(responseType);
+            if (item != null) { // we don't emit null because it breaks Multi (by design)
+                multiRequest.emit(item);
+            }
         }, multiRequest::fail, multiRequest::complete);
         // watch for user cancelling
         sseSource.registerAfterRequest(vertxResponse);