Apply suggestion

PicnicSupermarket · Sep 6, 2022 · 736bb18 · 736bb18
1 parent 32ae040
commit 736bb18
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/error-prone-contrib/src/main/java/tech/picnic/errorprone/bugpatterns/FluxFlatMapUsage.java b/error-prone-contrib/src/main/java/tech/picnic/errorprone/bugpatterns/FluxFlatMapUsage.java
@@ -59,7 +59,7 @@ public final class FluxFlatMapUsage extends BugChecker
           .namedAnyOf("flatMap", "flatMapSequential")
           .withParameters(Function.class.getName());
   private static final com.google.errorprone.suppliers.Supplier<Type> FLUX =
-      Suppliers.typeFromClass(Flux.class);
+      Suppliers.typeFromString("reactor.core.publisher.Flux");
 
   @Override
   public Description matchMethodInvocation(MethodInvocationTree tree, VisitorState state) {

diff --git a/...-prone-contrib/src/test/java/tech/picnic/errorprone/bugpatterns/FluxFlatMapUsageTest.java b/...-prone-contrib/src/test/java/tech/picnic/errorprone/bugpatterns/FluxFlatMapUsageTest.java
@@ -76,6 +76,7 @@ void replacementFirstSuggestedFix() {
             "",
             "class A {",
             "  private static final int MAX_CONCURRENCY = 8;",
+            "",
             "  void m() {",
             "    Flux.just(1).flatMap(Flux::just);",
             "    Flux.just(1).flatMapSequential(Flux::just);",
@@ -89,6 +90,7 @@ void replacementFirstSuggestedFix() {
             "",
             "class A {",
             "  private static final int MAX_CONCURRENCY = 8;",
+            "",
             "  void m() {",
             "    Flux.just(1).concatMap(Flux::just);",
             "    Flux.just(1).concatMap(Flux::just);",