Propagate backpressure correctly in MP REST Client SSE publisher #5425

eclipse-ee4j · Sep 27, 2023 · 99486b9 · 99486b9
1 parent 8a63706
commit 99486b9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-client/src/main/java/org/glassfish/jersey/microprofile/restclient/SseEventPublisher.java b/...-client/src/main/java/org/glassfish/jersey/microprofile/restclient/SseEventPublisher.java
@@ -66,7 +66,7 @@ public class SseEventPublisher extends EventInput implements Publisher<InboundEv
 
         this.executor = executor;
         this.genericType = genericType;
-        this.publisher = new JerseyPublisher<>(executor::submit, JerseyPublisher.PublisherStrategy.BEST_EFFORT);
+        this.publisher = new JerseyPublisher<>(executor::submit, JerseyPublisher.PublisherStrategy.BLOCKING);
     }
 
     private static final Logger LOG = Logger.getLogger(SseEventPublisher.class.getName());