Как в Reactor Netty обрабатывать ошибки внутри Flux?

Question

[Wan-Derer]

У меня есть Flux, в котором может быть, а может не быть error:

Flux<String> myFlux = Flux.create(sink -> {
  try {
    while (someCondition) {
      sink.next(someMethod());
    }
    sink.complete();
  } catch (Exception e) {
    sink.error(e);
  }
});

Теперь мне надо его отправить через Reactor Netty. В нормальной ситуации (когда нет error) я отправляю так:

public Publisher<Void> sendMyFlux(HttpServerRequest req, HttpServerResponse resp) {

  return resp
      .status(HttpResponseStatus.OK)
      .addHeader(ACCESS_CONTROL_ALLOW_ORIGIN, "*")     // CORS
      .sendString(myFlux);
}

А как сделать так чтобы при наличии error внутри Flux мне отправлять другой код (4хх) и не содержимое Flux, а текст с ошибкой?

Comments

[Dmitry Roo]

смотри методы:

[Wan-Derer]

Dmitry Roo, Я их видел, но что-то не соображу как обойтись без subscribe, так же как в исходном коде.

[Dmitry Roo]

Wan-Derer, что за «исходный код»?

[Wan-Derer]

Dmitry Roo, Тот который в вопросе

Answer 1

[Dmitry Roo]

Вам нужно.
- Сделать флюкс не строки, а какого-то своего типа, который будет содержать статус и саму строку
- Добавить логику, при которой статус будет зависить от содержания флюкса

Тогда методом .onErrorResume можно будет поймать исключение, обработать и добавить к ответу.