diff --git a/error-prone-contrib/src/main/java/tech/picnic/errorprone/refasterrules/ReactorRules.java b/error-prone-contrib/src/main/java/tech/picnic/errorprone/refasterrules/ReactorRules.java index 8426a5be53f..92e226421b2 100644 --- a/error-prone-contrib/src/main/java/tech/picnic/errorprone/refasterrules/ReactorRules.java +++ b/error-prone-contrib/src/main/java/tech/picnic/errorprone/refasterrules/ReactorRules.java @@ -1006,9 +1006,9 @@ static final class MonoFlatMapMany { Flux before( Mono mono, Function> function, + int prefetch, boolean delayUntilEnd, - int maxConcurrency, - int prefetch) { + int maxConcurrency) { return Refaster.anyOf( mono.map(function).flatMapMany(identity()), mono.flux().concatMap(function),