Skip to content

Commit

Permalink
Post-rebase fix
Browse files Browse the repository at this point in the history
  • Loading branch information
Stephan202 committed Oct 8, 2023
1 parent c419fd7 commit ce4405d
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1006,9 +1006,9 @@ static final class MonoFlatMapMany<S, T> {
Flux<T> before(
Mono<S> mono,
Function<? super S, ? extends Publisher<? extends T>> function,
int prefetch,
boolean delayUntilEnd,
int maxConcurrency,
int prefetch) {
int maxConcurrency) {
return Refaster.anyOf(
mono.map(function).flatMapMany(identity()),
mono.flux().concatMap(function),
Expand Down

0 comments on commit ce4405d

Please sign in to comment.