Использование RxNetty в качестве прокси-сервера без блокировки клиента

Question

У меня есть сервер RxNetty, который преобразует запросы и отправляет их через HTTP в другую службу. Я не нашел способ выполнить неблокирующий запрос с помощью HttpClient. Я хочу пропустить запрос на тайм-аут. Единственный способ я нашел, чтобы работать является:

client.submit(request) 
    .flatMap(response -> response.getContent(). 
     map(byteBuf -> byteBuf.toString(Charset.defaultCharset()))) 
    .toBlocking().toFuture().get(timeout, TimeUnit.MILLISECONDS); 

Answer 1

представить (запрос) .timeout (тайм-аут, TimeUnit.MILLISECONDS)