Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Align Mono#share() behavior with Flux#share, split sink impl out #2756

Merged
merged 6 commits into from
Sep 9, 2021
Merged

Align Mono#share() behavior with Flux#share, split sink impl out #2756

merged 6 commits into from
Sep 9, 2021

Commits on Sep 7, 2021

  1. Have Mono#share() behave more like Flux#share, split sink case out 

    TODO copy tests and amend NextProcessorTest
    @simonbasle
    simonbasle committed Sep 7, 2021
    Configuration menu
    Copy the full SHA
    ebb83d9 View commit details
    Browse the repository at this point in the history

  2. Sinks.one() not fuseable for now, removing one unrelated test dependi… 

    …ng on fusion
    @simonbasle
    simonbasle committed Sep 7, 2021
    Configuration menu
    Copy the full SHA
    e54e369 View commit details
    Browse the repository at this point in the history

  3. Fix overflow message in InternalOneSink

    @simonbasle
    simonbasle committed Sep 7, 2021
    Configuration menu
    Copy the full SHA
    078a069 View commit details
    Browse the repository at this point in the history

  4. add tests, add scan(RUN_STYLE), extend block

    @simonbasle
    simonbasle committed Sep 7, 2021
    Configuration menu
    Copy the full SHA
    1fc32c6 View commit details
    Browse the repository at this point in the history

Commits on Sep 8, 2021

  1. actually add a subscriber when NextProcessor.subscribe()

    @simonbasle
    simonbasle committed Sep 8, 2021
    Configuration menu
    Copy the full SHA
    7de56f8 View commit details
    Browse the repository at this point in the history

  2. fix couple of tests

    @simonbasle
    simonbasle committed Sep 8, 2021
    Configuration menu
    Copy the full SHA
    621f038 View commit details
    Browse the repository at this point in the history