Как написать ярлык в реакторном режиме - PullRequest
Новая
       7

Как написать ярлык в реакторном режиме

0 голосов
/ 19 апреля 2019

У меня есть нереакторный код моды, как показано ниже, итерация по списку шашек и возврат ярлыка «ПЛОХО», если какой-либо из них возвращает false: 

public static String oldWay() {
    List<Checker> checkers = new ArrayList<>();
    String param = "blahblah";
    for (Checker checker : checkers) {
      if (!checker.check(param)) {
        return "BAD";
      }
    }
    return "GOOD";
}

interface Checker {
  boolean check(String str);
  Mono<Boolean> reactorCheck(String str);
}

Как я могу преобразовать указанный выше код в моду реактора? 

public static Mono<String> newWay() {
  // TODO
  return Mono.just("GOOD");
}

1 Ответ

1 голос
/ 19 апреля 2019

Включите его и используйте Flux#all(Predicate), но входной поток является одним из всех Checker, которые вы хотите проверить: 

//simplified Checker version for this example
interface Checker extends Predicate<String> {}

@Test
public void allChecks() {
    //given the checks you want to apply, as a Flux<Checker>...
    Checker lengthy = s -> s.length() > 3;
    Checker startsWithA = s -> s.toUpperCase().startsWith("A");

    Flux<Checker> checks = Flux.just(lengthy, startsWithA);

    //...and given the param String you want to check...
    String param = "Boooooh";
    //... verify that _all_ checkers match the predicate that "param passes the checker"
    Mono<String> allChecks = checks.all(checker -> checker.test(param))
        //and map that result to GOOD or BAD
          .map(allMatch -> allMatch ? "GOOD" : "BAD");

    StepVerifier.create(allChecks)
                .expectNext("BAD")
                .verifyComplete();

    //variant when multiple params to test:
    Flux<String> params = Flux.just("Booooh", "Always", "Ace");
    Flux<String> multiParamChecks = params.flatMap(p -> checks
            .all(checker -> checker.test(p))
            .map(valid -> p + (valid ? " GOOD" : " BAD"))
    );

    StepVerifier.create(multiParamChecks)
                .expectNext("Booooh BAD")
                .expectNext("Always GOOD")
                .expectNext("Ace BAD")
                .verifyComplete();
}
...