Обработка списка IP-адресов с помощью Reactor Netty HttpClient ⇐ JAVA

[Anonymous]

Я пытаюсь обработать сценарии черного списка IP-адресов в Reactor Netty HttpClient. Я реализовал проверку черного списка с помощью doAfterResolve, как показано ниже:

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

var httpClient = reactor.netty.http.client.HttpClient.create()
// ...
httpClient = httpClient.doAfterResolve((conn, addr) -> {
InetAddress address = ((InetSocketAddress) addr).getAddress();
if (isBlocked(address))
throw new IllegalStateException("IP is blocked");
});

Однако, когда исключение создается, оно не передается обработчику doOnError в моей цепочке запросов:

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

httpRequest
.retrieve()
// ...
.doOnError(e -> {
// Expect error handling here
})
.toFuture();

Я ожидал, что исключение, созданное в doAfterResolve, будет перехвачено обработчиком doOnError, но, похоже, этого не произошло. Как правильно обработать эту ошибку в цепочке запросов?

Подробнее здесь: https://stackoverflow.com/questions/793 ... httpclient