Apply suggestion

This commit is contained in:
Elena Liashenko
2022-09-06 13:50:55 +02:00
committed by Stephan Schroevers
parent d3b3d433f9
commit cb440d2077
2 changed files with 3 additions and 1 deletions

View File

@@ -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) {

View File

@@ -76,6 +76,7 @@ final class FluxFlatMapUsageTest {
"",
"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 @@ final class FluxFlatMapUsageTest {
"",
"class A {",
" private static final int MAX_CONCURRENCY = 8;",
"",
" void m() {",
" Flux.just(1).concatMap(Flux::just);",
" Flux.just(1).concatMap(Flux::just);",