Как продолжить последовательность fluxMap после исключения ⇐ JAVA

[Anonymous]

Я новичок в проекте «Реактор» и столкнулся с проблемой. Вот пример кода:

Код: Выделить всё

// 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