Apply suggestion

PicnicSupermarket · Sep 8, 2022 · dcd5811 · dcd5811
1 parent bf7d5b4
commit dcd5811
Showing 1 changed file with 8 additions and 6 deletions.
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
@@ -34,9 +34,9 @@ void identification() {
             "    // BUG: Diagnostic contains:",
             "    Flux.just(1).<String>flatMapSequential(i -> Flux.just(String.valueOf(i)));",
             "    // BUG: Diagnostic contains:",
-            "    Flux.just(\"test_1\",\"test\").groupBy(String::length).flatMap(Flux::just);",
+            "    Flux.just(\"test_1\", \"test\").groupBy(String::length).flatMap(Flux::just);",
             "    // BUG: Diagnostic contains:",
-            "    Flux.just(\"test_1\",\"test\").groupBy(String::length).flatMapSequential(Flux::just);",
+            "    Flux.just(\"test_1\", \"test\").groupBy(String::length).flatMapSequential(Flux::just);",
             "",
             "    Mono.just(1).flatMap(Mono::just);",
             "    Flux.just(1).concatMap(Flux::just);",
@@ -80,8 +80,8 @@ void replacementFirstSuggestedFix() {
             "  void m() {",
             "    Flux.just(1).flatMap(Flux::just);",
             "    Flux.just(1).flatMapSequential(Flux::just);",
-            "    Flux.just(\"test_1\",\"test\").groupBy(String::length).flatMap(Flux::just);",
-            "    Flux.just(\"test_1\",\"test\").groupBy(String::length).flatMapSequential(Flux::just);",
+            "    Flux.just(\"test_1\", \"test\").groupBy(String::length).flatMap(Flux::just);",
+            "    Flux.just(\"test_1\", \"test\").groupBy(String::length).flatMapSequential(Flux::just);",
             "  }",
             "}")
         .addOutputLines(
@@ -94,8 +94,10 @@ void replacementFirstSuggestedFix() {
             "  void m() {",
             "    Flux.just(1).concatMap(Flux::just);",
             "    Flux.just(1).concatMap(Flux::just);",
-            "    Flux.just(\"test_1\",\"test\").groupBy(String::length).flatMap(Flux::just, MAX_CONCURRENCY);",
-            "    Flux.just(\"test_1\",\"test\").groupBy(String::length).flatMapSequential(Flux::just, MAX_CONCURRENCY);",
+            "    Flux.just(\"test_1\", \"test\").groupBy(String::length).flatMap(Flux::just, MAX_CONCURRENCY);",
+            "    Flux.just(\"test_1\", \"test\")",
+            "        .groupBy(String::length)",
+            "        .flatMapSequential(Flux::just, MAX_CONCURRENCY);",
             "  }",
             "}")
         .doTest();