rsocket-java

rsocket-java copied to clipboard

java.util.concurrent.CancellationException: Disposed when disposing flux from channel communication in tests

5

I have created a sample application which uses `channel` style communication. Unfortunatelly when cancelling the subscription from the tests I receive an exception : stacktrace ```` 022-04-10 20:33:49.106 ERROR 338925...

mkrzywanski

QUIC Transport Support

10

We know QUIC has become the IETF standard, and netty supports QUIC . Do we have any plans to support it?

atshow

closes #1045 Signed-off-by: Oleh Dokuka Signed-off-by: Oleh Dokuka

OlegDokuka

If compression is enabled on client and server, the client acceptor fails with `ArrayIndexOutOfBoundsException` if it tries to access properties of `ConnectionSetupPayload`. Here is the diff with changes to the...

rstoyanchev

At the moment we have a number of concurrency tests in the tests codebase but we need to have a more stable source of truth and tooling designed to uncovering...

OlegDokuka

Signed-off-by: Oleh Dokuka Signed-off-by: Oleh Dokuka

OlegDokuka

Support returning ApplicationError with cause

1

Rsocket define two ApplicationError constructors, which match the standard Java Exception interface: ``` Java public final class ApplicationErrorException extends RSocketErrorException { private static final long serialVersionUID = 7873267740343446585L; /** *...

LifeIsStrange

add auto reconnection option

4

It would be convenient to have two options for setting up a connection: lazy on any first call and automatic when the server is available. For example, chat. It is...

sergey-mesh

Is there a way to wait for RSocket requests to finish before cutting them off at the knees? > Oleh Dokuka < 1 minute ago We need to add that....

dsyer

provides reworked AeronTransport implementation

1

Signed-off-by: Oleh Dokuka

OlegDokuka