Build #3,025

Build: #3025 failed Changes by Simon Baslé <sbasle@vmware.com>

Code commits

reactor-core

  • Simon Baslé <sbasle@vmware.com>

    Simon Baslé <sbasle@vmware.com> d22f352495c3803c206c4a2b998772fa7873e5ff

    Merge #2567 into 3.4.3

  • Tomas Kolda <koldat@gmail.com>

    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)