Я новичок в проекте «Реактор» и столкнулся с проблемой. Вот пример кода:
Код: Выделить всё
// Message has a type of SomeClass
flux.flatMap(message -> someService.someOperationReturningMono(...)
.flatMap(i -> anotherService.operationWichCanProducerException(message.getProperty()))
.flatMap(j -> anotherService.operationWichCanProducerException(message.getProperty())))
.then()
.onErrorContinue(...)
.subscribe(...);
Проблема в том, что первый вызов может вызвать исключение, и из-за этого второй вызов не произойдет, потому что, как я знаю, после первого исключения в цепочке оригинальный Publisher завершает работу, но для меня это важно чтобы гарантировать второй вызов метода службы. Более того, в будущем таких вызовов будет больше, потому что фактические параметры всегда разные. Есть ли способ гарантировать, что если во время вызова метода службы возникнет какое-либо исключение, методы службы из следующих плоских карт все равно будут вызываться?
Подробнее здесь:
https://stackoverflow.com/questions/790 ... -exception