Skip to content

Commit

Permalink
Propagate back-pressure correctly in MP REST Client SSE publisher (#5426
Browse files Browse the repository at this point in the history
)

* Propagate backpressure correctly in MP REST Client SSE publisher #5425
  • Loading branch information
danielkec authored Oct 10, 2023
1 parent 8a63706 commit 3aaa3f9
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright (c) 2021 Oracle and/or its affiliates. All rights reserved.
* Copyright (c) 2021, 2023 Oracle and/or its affiliates. All rights reserved.
* Copyright (c) 2021 Payara Foundation and/or its affiliates. All rights reserved.
*
* This program and the accompanying materials are made available under the
Expand Down Expand Up @@ -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());
Expand Down

0 comments on commit 3aaa3f9

Please sign in to comment.