Build: #3025 failed Changes by Simon Baslé <sbasle@vmware.com>
Code commits
reactor-core
-
Simon Baslé <sbasle@vmware.com> d22f352495c3803c206c4a2b998772fa7873e5ff
Merge #2567 into 3.4.3
-
Tomas Kolda <koldat@gmail.com> 31254c676c9c5382050508d722a9063b17b5e691 m
Fix OverflowException in MultiSubscriptionSubscriber (#2576)
This commit fixes an OverflowException when using concatMap and/or
Flux.just, finding its root in `MultiSubscriptionSubscriber` request
accounting.
It changes the underlying subscription of `Flux.just` to become a
ScalarSubscription, as the lack of volatile was causing race conditions.
It also allows to set up a predefined `stepName` for ScalarSubscription,
in order to maintain the stepName of `Flux.just` as it was before.
Fixes #2567.- reactor-core/src/main/java/reactor/core/publisher/FluxJust.java (version 31254c676c9c5382050508d722a9063b17b5e691)
- reactor-core/src/main/java/reactor/core/publisher/Operators.java (version 31254c676c9c5382050508d722a9063b17b5e691)
- reactor-core/src/test/java/reactor/core/publisher/FluxConcatWithTest.java (version 31254c676c9c5382050508d722a9063b17b5e691)
- reactor-core/src/test/java/reactor/core/publisher/FluxJustTest.java (version 31254c676c9c5382050508d722a9063b17b5e691)
- reactor-core/src/test/java/reactor/core/publisher/OperatorsTest.java (version 31254c676c9c5382050508d722a9063b17b5e691)