Блог

Я пытаюсь проверить значения a list , используя a reactor.core.publisher.Flux внутри a try catch , но когда map генерируется исключение catch , оно вообще не улавливается. Я действительно не понимаю, что здесь происходит. Некоторая помощь была бы признательна.

Это именно то, что я пытаюсь сделать:

  public Flux<Something> execute(final List<Line> lines) {
        try {
          return this.getFlux(lines)
              .map(line -> this.validateLine(line))//this throws my custom exception if the condition applies
              .map(line -> this.doSomething(line))
              .map(line -> this.doSomethingElse(line));

        } catch (myCustomException e) {
            return something;
        }
  }
 

Я вижу validate , что метод работает хорошо и выдает исключение путем отладки, но catch , похоже, он не работает, и я не вижу, что не так.

Вам потребуется операция терминала, применяемая к концу потока. Потоки оцениваются лениво.