Apply suggestion

PicnicSupermarket · Jan 15, 2024 · 015c221 · 015c221
1 parent 9607fbd
commit 015c221
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 10 deletions.
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
@@ -1612,7 +1612,7 @@ Mono<T> before(Flux<T> flux) {
 
     @AfterTemplate
     Mono<T> after(Flux<T> flux) {
-      return flux.transform(MathFlux::min).next();
+      return flux.transform(MathFlux::min).singleOrEmpty();
     }
   }
 
@@ -1629,7 +1629,7 @@ Mono<T> before(Flux<T> flux, Comparator<? super T> cmp) {
 
     @AfterTemplate
     Mono<T> after(Flux<T> flux, Comparator<? super T> cmp) {
-      return flux.transform(f -> MathFlux.min(f, cmp)).next();
+      return flux.transform(f -> MathFlux.min(f, cmp)).singleOrEmpty();
     }
   }
 
@@ -1642,7 +1642,7 @@ Mono<T> before(Flux<T> flux) {
 
     @AfterTemplate
     Mono<T> after(Flux<T> flux) {
-      return flux.transform(MathFlux::max).next();
+      return flux.transform(MathFlux::max).singleOrEmpty();
     }
   }
 
@@ -1659,7 +1659,7 @@ Mono<T> before(Flux<T> flux, Comparator<? super T> cmp) {
 
     @AfterTemplate
     Mono<T> after(Flux<T> flux, Comparator<? super T> cmp) {
-      return flux.transform(f -> MathFlux.max(f, cmp)).next();
+      return flux.transform(f -> MathFlux.max(f, cmp)).singleOrEmpty();
     }
   }
 

diff --git a/...ntrib/src/test/resources/tech/picnic/errorprone/refasterrules/ReactorRulesTestOutput.java b/...ntrib/src/test/resources/tech/picnic/errorprone/refasterrules/ReactorRulesTestOutput.java
@@ -530,23 +530,23 @@ Flux<Integer> testFluxSort() {
   }
 
   Mono<Integer> testFluxTransformMin() {
-    return Flux.just(1).transform(MathFlux::min).next();
+    return Flux.just(1).transform(MathFlux::min).singleOrEmpty();
   }
 
   ImmutableSet<Mono<Integer>> testFluxTransformMinWithComparator() {
     return ImmutableSet.of(
-        Flux.just(1).transform(f -> MathFlux.min(f, reverseOrder())).next(),
-        Flux.just(2).transform(f -> MathFlux.min(f, reverseOrder())).next());
+        Flux.just(1).transform(f -> MathFlux.min(f, reverseOrder())).singleOrEmpty(),
+        Flux.just(2).transform(f -> MathFlux.min(f, reverseOrder())).singleOrEmpty());
   }
 
   Mono<Integer> testFluxTransformMax() {
-    return Flux.just(1).transform(MathFlux::max).next();
+    return Flux.just(1).transform(MathFlux::max).singleOrEmpty();
   }
 
   ImmutableSet<Mono<Integer>> testFluxTransformMaxWithComparator() {
     return ImmutableSet.of(
-        Flux.just(1).transform(f -> MathFlux.max(f, reverseOrder())).next(),
-        Flux.just(2).transform(f -> MathFlux.max(f, reverseOrder())).next());
+        Flux.just(1).transform(f -> MathFlux.max(f, reverseOrder())).singleOrEmpty(),
+        Flux.just(2).transform(f -> MathFlux.max(f, reverseOrder())).singleOrEmpty());
   }
 
   ImmutableSet<Mono<Integer>> testMathFluxMin() {