rx-netty

0зной

1ответ

Почему RxNetty использует threadpools?

Недавно я увидел io.reactivex.netty.client.PoolExhaustedException. Разве нетто не должно запускаться с использованием O (1) числа потоков? не рекламируется ли он как асинхронный, неблокирующий, исполь

java netty nio rx-netty 2016-11-16

---

0зной

1ответ

Почему нетто-клиент возвращается Наблюдаемый <Наблюдаемый <ByteBuf>> вместо наблюдаемого <ByteBuf>?

учебник/примеры показывают: Observable<HttpClientResponse<ByteBuf>> httpGet = RxNetty.createHttpGet("http://xxxx"); Observable<Observable<ByteBuf>> byteBuffers = httpGet.m

java netty reactive-programming rx-netty 2016-11-27

---

0зной

1ответ

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

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

rx-java rx-netty 2015-12-17

---

0зной

1ответ

Как использовать TestScheduler с HTTP-сервером RxNetty

Я пытаюсь создать сервер имитации, чтобы упростить запись тестов для клиента, который работает с потоком событий. Я реализую сервер и клиент с RxNetty, мой вопрос в том, как я могу использовать TestSc

java rx-java rx-netty 2015-12-22

---

0зной

1ответ

rxnetty пул соединений бросает PoolExhaustedException

Когда я использую rxnetty пул соединений, я получил следующие ошибки io.reactivex.netty.client.PoolExhaustedException в io.reactivex.netty.client.ConnectionPoolImpl $ 1.call (ConnectionPoolImpl .java:

exception connection netty pool rx-netty 2016-10-18

---

1зной

1ответ

Как перехватить код в пуле потоков rx-netty

У меня есть данные, хранящиеся в ThreadLocal (например, MDC), и мне нужно его обновить для каждого запроса. Использование http-клиента rx-netty Я ставлю это значение как заголовок http, но не могу най

httpclient netty rx-netty 2015-12-31

---

0зной

2ответ

RxNetty как использовать onErrorResumeNext

У меня возникла проблема, чтобы получить остальную часть элементов из наблюдаемого после того, как вы выбрали исключение. Предположим, что у меня есть 10 элементов для испускания, во втором элементе я

rx-netty 2016-11-03

---

0зной

1ответ

Фрагмент кода примеров Нетти из netty.io кажется есть ошибки

Фрагмент кода: final ChannelFuture f = ctx.writeAndFlush(time); f.addListener(new ChannelFutureListener() { public void operationComplete(ChannelFuture future) { assert f == fut

netty rx-netty 2016-04-19

---