Build #2,211

Build: #2211 was successful Changes by Stephane Maldini <smaldini@pivotal.io> and Simon Basle

Code commits

reactor-core

  • Simon Basle

    Simon Basle 64318b5f36e30c5cb9ddc0742d15778ce773d5f7

    fix #1114 Resolve to 1st context found for multi-subscribers
    Note that due to the multi-subscriber nature of those processors or
    operators, context availability is volatile as subscribers may
    come and go concurrently.
    A small tweak has been applied to fluxReplay to make sure the subscribers
     list is being updated before source subscribe

    • reactor-core/src/test/java/reactor/core/publisher/scenarios/MonoTests.java (version 64318b5f36e30c5cb9ddc0742d15778ce773d5f7)
    • reactor-core/src/test/java/reactor/core/publisher/MonoCacheTimeTest.java (version 64318b5f36e30c5cb9ddc0742d15778ce773d5f7)
    • reactor-core/src/test/java/reactor/core/publisher/FluxReplayTest.java (version 64318b5f36e30c5cb9ddc0742d15778ce773d5f7)
    • reactor-core/src/test/java/reactor/core/publisher/FluxCacheTest.java (version 64318b5f36e30c5cb9ddc0742d15778ce773d5f7)
    • reactor-core/src/main/java/reactor/core/publisher/ReplayProcessor.java (version 64318b5f36e30c5cb9ddc0742d15778ce773d5f7)
    • reactor-core/src/main/java/reactor/core/publisher/Operators.java (version 64318b5f36e30c5cb9ddc0742d15778ce773d5f7)
    • reactor-core/src/main/java/reactor/core/publisher/MonoProcessor.java (version 64318b5f36e30c5cb9ddc0742d15778ce773d5f7)
    • reactor-core/src/main/java/reactor/core/publisher/MonoCacheTime.java (version 64318b5f36e30c5cb9ddc0742d15778ce773d5f7)
    • reactor-core/src/main/java/reactor/core/publisher/FluxReplay.java (version 64318b5f36e30c5cb9ddc0742d15778ce773d5f7)
  • Stephane Maldini <smaldini@pivotal.io>

    Stephane Maldini <smaldini@pivotal.io> 6016be41554389583a9b5d54bbe9ab2204e8cddc

    Simplify MonoProcessor internals in preparation for #1114 and further 3.2 changes
    Fix double MonoProcessor subscribe in toProcessor

    • reactor-core/src/test/java/reactor/core/publisher/MonoProcessorTest.java (version 6016be41554389583a9b5d54bbe9ab2204e8cddc)
    • reactor-core/src/main/java/reactor/core/publisher/MonoProcessor.java (version 6016be41554389583a9b5d54bbe9ab2204e8cddc)
    • reactor-core/src/main/java/reactor/core/publisher/MonoCompletionStage.java (version 6016be41554389583a9b5d54bbe9ab2204e8cddc)
    • reactor-core/src/main/java/reactor/core/publisher/Mono.java (version 6016be41554389583a9b5d54bbe9ab2204e8cddc)