RxNetty

RxNetty copied to clipboard

Is the RxNetty project still alive?

5

Just asking because there doesn't seem to be a lot of activity.

karel1980

ReactiveStreams support

9

There have been some discussions in #565 and #561 around upgrading RxJava to 2.x in RxNetty. I would like to spin that into the following: _Make RxNetty stick to exposing...

NiteshKant

Hi! I'm trying to write microservice using RxNetty and stuck on implementing HTTPS support for it. I have certificate chain in PEM format and a private key for domain ikeybase.ru,...

ikey-ru

Upgrade Response should not contain "transfer-encoding"

3

Hi, I'm experimenting with the example here [1]. When inspecting the request/response headers I see that RxNetty includes "transfer-encoding" to the response's headers when switching the protocols. This header is...

violetagg

io.reactivex.netty.client.PoolExhaustedException although pool is at 12k and we're receiving 2k QPS

21

Hi, We're seing the following errors on our proxy server: ``` java io.reactivex.netty.client.PoolExhaustedException at io.reactivex.netty.client.ConnectionPoolImpl$1.call(ConnectionPoolImpl.java:147) at io.reactivex.netty.client.ConnectionPoolImpl$1.call(ConnectionPoolImpl.java:117) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at...

Crystark

Hi we are using netty version : 4.1.29.Final Maven dependencies are below ` io.netty netty-all ${netty.version} io.reactivex rxnetty 0.4.20 io.reactivex rxnetty-servo 0.4.20 io.reactivex rxjava 1.3.8 io.reactivex rxjava-computation-expressions 0.21.0 ` Seeing...

kotlapraveen

[SECURITY] unsafeSecure() should not be used in samples

1

[Insecure example code leads to insecure production code](https://www.synopsys.com/blogs/software-security/insecure-example-code-insecure-production-code/) By offering "working" code that is insecure by default, you are inherently suggesting that users use insecure coding practices by default. For...

JLLeitschuh

HTTP POST example (REST)

4

Hi all, I am after a working HTTP POST example. I can get the TCP example to send data to server but all the HTTP examples are too simplified. Is...

gadieichhorn

Connection Leak 0.5.2

6

for our project, https://github.com/Azure/azure-cosmosdb-java, we are trying to upgrade our dependency on RxNetty from 0.4.x to 0.5.2 however it seems there is a connection leak issue in 0.5.2 that we...

moderakh

What could cause the RxNetty client to return an empty stream ?

8

I'm using a fairly simple RxNetty client: ``` java public Service(String host, int port, int maxConnection) { endpoint = RxNetty . newHttpClientBuilder(host, port) .withMaxConnections(maxConnection) .build(); } public Observable submit(Observable o)...

Crystark