Возвращать предыдущие успешные ответы при возникновении исключения с использованием Java Flux ⇐ JAVA

[Anonymous]

Может кто-нибудь подсказать мне, поскольку я новичок в потоке и пытаюсь понять, как справиться с этим сценарием?
Проблема: я получаю исключение readTimeout в одном из ответов потока от метода getResp() ниже, а затем все предыдущие успешные ответы игнорируются и возвращается ошибка исключения.
Вместо этого я хочу вернуть все успешные ответы, которые я получил до исключения.

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

public Flux getInfo(List requestObjList) {
return requestObjList.stream()
.parallel()
.map(this::getResp)
.reduce(Flux::Merge)
.orElse(Flux.empty());
}

public Flux getResp(RequestObj requestObj){
// process the request and return ...

}

Если что-то неясно, дайте мне знать, мы будем рады предоставить более подробную информацию.

Подробнее здесь: https://stackoverflow.com/questions/717 ... -java-flux