Simon Baslé
Simon Baslé
This PR introduces several concepts: - a generic `FunctionalWrappers` interface that defines wrappers for all functional types used by Reactor API - a contextual implementation of the above in `ContextPropagation`...
In this PR we introduce a `ContextPropagation` runtime-detection utility class as well as a `contextCapture()` operator. If context-propagation isn't on the classpath, this operator is NO-OP. If context-propagation _is_ on...
This PR adds the `Contextual` interface to denote an object that has a `ContextView` attached. It also adds a new variant of the `Schedulers#onScheduleHook` that takes a `BiFunction`, allowing to...
The `Scheduler` interface has 3 submit methods and 3 mirroring methods on the `Scheduler.Worker` interface. Additionally, all *vanilla* `Scheduler` used in Reactor come from the `Schedulers` factory, which offers a...
This section of the reference guide is outdated, with the introduction of `reactor-core-micrometer` module and the latest improvements in M4.
3.6.0 is the **earliest** version at which these deprecation can be removed (add to the list as relevant). For reference: - #2596 : switchOnNext and switchMap with prefetch parameter ##...
## Motivation Currently, `Sinks.many()` produces sinks that fail fast in case parallel use is detected. - This allows to get immediate and explicit feedback from the `tryEmitXxx` API. - The...
The way fields are laid out is changing in Java 15, allowing fields from a sub-class to be stored in the unused space of a super-class's field (and breaking the...
Provide an option (now Spec) per subscriber, don't expose ctx write methods. We expose one ScopeMutableSpec per Subscriber, which is passed to a Consumer so that users can tune the...