Dariusz Jędrzejczyk
Dariusz Jędrzejczyk
The fair backpressure variant of the `bufferTimeout` operator has been reworked to use a state machine with a minimum number of volatile variables eliminating potential data races, such as skipping...
This issue is meant to coordinate tasks required for context-propagation library integration and propagation of `ThreadLocal` values in Reactor to be in a desired state. More details to come. -...
Similarly to the way `Retry` is implemented with accompanying `retryWhen(RetrySpec)` operator, the `Repeat` functionality from reactor-addons project should be implemented in reactor-core and phased out from reactor-extras (module of reactor-addons)....
Follow up from #3332 - there is a chance we can reduce the amount of volatile fields to improve the performance of the bufferTimeout with fair backpressure operator.
Currently, automatic context propagation using the `context-propagation` library uses a `Hooks.addQueueWrapper` method to register `ContextQueue`, an envelope mechanism to aid in propagating `ThreadLocal` context across `Thread` boundaries. The implementation restores...
In #3325 @violetagg added reflection hints for AOT builds and tested against spring smoke tests. We should be able to provide a smoke test within reactor-core repository. The below can...
Some operators report incorrect `RUN_STYLE` from the `Scannable::scanUnsafe(Attr key)` implementations. These incorrect responses can (and most probably do) cause errors in usages that scan the reactive pipeline to infer asynchronous...
JCStress is more flexible than `RaceTestUtils` utility, internal to reactor-core. There are some concurrency stress tests hidden in integration tests. We should move them to JCStress tests. The following list...
This change adds information about the required runtime dependency of reactor-extras for the deprecated extension methods for repeat and retry operations.
Once https://github.com/reactor/reactor-core/issues/3545 is implemented, `Repeat` functionality can be deprecated in the same way as `Retry` [has already been](https://github.com/reactor/reactor-addons/issues/278).