Skip to content

Commit 01240b9

Browse files
authored
Merge pull request quarkusio#36450 from geoand/sse-null
Don't emit null values from SSE
2 parents b2179b8 + d7911a1 commit 01240b9

File tree

1 file changed

+4
-1
lines changed
  • independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl

1 file changed

+4
-1
lines changed

independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/impl/MultiInvoker.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,10 @@ private <R> void registerForSse(MultiRequest<? super R> multiRequest,
163163
sseSource.register(event -> {
164164
// DO NOT pass the response mime type because it's SSE: let the event pick between the X-SSE-Content-Type header or
165165
// the content-type SSE field
166-
multiRequest.emit(event.readData(responseType));
166+
R item = event.readData(responseType);
167+
if (item != null) { // we don't emit null because it breaks Multi (by design)
168+
multiRequest.emit(item);
169+
}
167170
}, multiRequest::fail, multiRequest::complete);
168171
// watch for user cancelling
169172
sseSource.registerAfterRequest(vertxResponse);

0 commit comments

Comments
 (0)