Skip to content

Commit

Permalink
Suggestion
Browse files Browse the repository at this point in the history
  • Loading branch information
Stephan202 committed Jan 15, 2022
1 parent 5d362c2 commit f68492e
Showing 1 changed file with 2 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@
import reactor.core.publisher.Mono;
import reactor.test.StepVerifier;
import reactor.test.publisher.PublisherProbe;
import tech.picnic.errorprone.bugpatterns.FluxFlatMapUsageCheck;

/** Refaster templates related to Reactor expressions and statements. */
final class ReactorTemplates {
Expand Down Expand Up @@ -157,11 +156,8 @@ Flux<S> after(Flux<T> flux, Function<? super T, ? extends Publisher<? extends S>
}

/**
* Prefer {@link Flux#concatMapIterable(Function)} over {@link Flux#concatMapIterable(Function)}
* to be consistent with {@link FluxFlatMapUsageCheck}.
*
* <p>NB: Both implementations emit values in a deterministic order and there is no difference
* with eager or lazy inner subscriptions. This means that both implementations are *equivalent*.
* Prefer {@link Flux#concatMapIterable(Function)} over {@link Flux#concatMapIterable(Function)},
* as the former has equivalent semantics but a clearer name.
*/
static final class FluxConcatMapIterable<T, S> {
@BeforeTemplate
Expand Down

0 comments on commit f68492e

Please sign in to comment.