Dariusz Jędrzejczyk
Dariusz Jędrzejczyk
Approved, although I left a few comments - some are minor, for the docs; one I believe to be important for UX, but possible to improve as a follow-up if...
As a matter of fact, the case is different from `reactor.core.publisher.FluxConcatArray`. The code is creating a recursion, for which we don't have a way to overcome. The subscription flow is...
The reactive chain is unable to terminate `block` on such an occasion, as when a `SOE` happens, the terminal signal can't be delivered to `block`'s subscriber. All in all, JVM...
> @chemicL what do you think of this piece of code to shutdown multiple executors at once, try to await as close to the grace period as possible while still...
The latest changes include improvements for avoiding looping in the `dispose`/`disposeGracefully`/`start` methods as suggested by @OlegDokuka. This was only possible by revisiting `BoundedElasticScheduler`'s inner workings and avoiding atomic replacing of...
@ZejiaJiang we are discussing the API that is in draft state in #3089. We are considering two possible behaviours. First the API: ``` Mono disposeGracefully(Duration gracefulPeriod); ``` which can either...
@cavallium thank you for sharing. Do you think the proposed solutions can aid in simplifying your code? If you have any comments regarding the `disposeGracefully(Duration)` mechanics described in this discussion,...
@ZejiaJiang @cavallium first of all, thank you for the feedback and ideas. After some back-and-forth we landed on a design, that should be the least surprising to users. A `disposeGracefully()`...
Consider experimenting with the snapshot version, we can integrate the feedback in the release.
@cavallium can you be more specific here?: > By the way, if a Flux is cancelled it will still call dispose, is there a way to prevent it? Do you...