Introduce assorted Reactor Refaster rules #763
Conversation
|
Looks good. No mutations were possible for these changes. |
Stephan202
force-pushed
the
sschroevers/introduce-assorted-reactor-rules
branch
from
e5bae56
to
45b40de
Compare
|
Looks good. No mutations were possible for these changes. |
|
Kudos, SonarCloud Quality Gate passed!
|
| return flux.flatMapIterable(function); | ||
| return Refaster.anyOf( | ||
| flux.flatMapIterable(function), flux.map(function).concatMapIterable(identity())); |
There was a problem hiding this comment.
The documentation of this method is outdated now. 👍
| @BeforeTemplate | ||
| Flux<S> before( | ||
| Flux<T> flux, Function<? super T, ? extends Iterable<? extends S>> function, int prefetch) { | ||
| return flux.flatMapIterable(function, prefetch); | ||
| return Refaster.anyOf( | ||
| flux.flatMapIterable(function, prefetch), | ||
| flux.map(function).concatMapIterable(identity(), prefetch)); | ||
| } |
Stephan202
force-pushed
the
sschroevers/introduce-assorted-reactor-rules
branch
from
45b40de
to
18a1528
Compare
|
Tnx for the review @werli! Rebased and added a commit. |
|
Looks good. No mutations were possible for these changes. |
|
Kudos, SonarCloud Quality Gate passed!
|
Flushing a bunch of changes I had collected locally. This could be split into multiple PRs. Let me know if anybody feels strongly enough about that.
Suggested commit messages: