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

Add doOnEach(Consumer<? super Signal<T>> signalConsumer) equivalent in ParrelelFlux and Mono #344

Closed
dfeist opened this issue Jan 8, 2017 · 1 comment
Closed

Add doOnEach(Consumer<? super Signal<T>> signalConsumer) equivalent in ParrelelFlux and Mono #344

dfeist opened this issue Jan 8, 2017 · 1 comment
Assignees
@simonbasle
Labels
type/enhancement A general enhancement
Milestone
3.0.5.RELEASE

Comments

@dfeist
Copy link
Contributor

dfeist commented Jan 8, 2017 •
edited by simonbasle
Loading

What @simonbasle added in e1b28e1 is pretty cool/useful, just a shame there isn't an equivalent in Mono/ParrelelFlux as it'd be useful, and for consistency of course.

Another option with ParrelelFlux is to keep it as tight as possible, and not duplicate any but the most used operators, and then allow Flux operators to be used via #283 e.g.

parallelFlux.transformRail(flux -> flux.doOnEach(..))
@simonbasle simonbasle self-assigned this Jan 9, 2017
@simonbasle simonbasle added this to the 3.0.5.RELEASE milestone Jan 9, 2017
@smaldini
Copy link
Contributor

Fixed by #348

@smaldini smaldini added the type/enhancement A general enhancement label Jan 10, 2017
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@simonbasle simonbasle

Labels
type/enhancement A general enhancement
Projects
None yet
Milestone
3.0.5.RELEASE
Development

No branches or pull requests
3 participants
@smaldini @dfeist @simonbasle