rsocket-java
rsocket-java copied to clipboard
rsocket
Java implementation of RSocket
I am running into a deadlock between close and cancel when multiple rsocket channels output goes through FluxMerge reactor operator with output to a single rsocket channel. Is there any...
> 2022-08-08 21:58:55.982 27203-27265/com.example.rsocket E/AndroidRuntime: FATAL EXCEPTION: DefaultDispatcher-worker-2 Process: com.example.rsocket, PID: 27203 UnsupportedSetupException (0x2): resume not supported at io.rsocket.exceptions.Exceptions.from(Exceptions.java:60) at io.rsocket.core.RSocketRequester.lambda$tryTerminateOnZeroError$4(RSocketRequester.java:313) at io.rsocket.core.-$$Lambda$RSocketRequester$rwbq8EQ-eZ8va-mvaHgd0inROSU.get(Unknown Source:2) at io.rsocket.core.RSocketRequester.tryTerminate(RSocketRequester.java:318) at io.rsocket.core.RSocketRequester.tryTerminateOnZeroError(RSocketRequester.java:313) at io.rsocket.core.RSocketRequester.handleStreamZero(RSocketRequester.java:224)...
It is not clear if it is possible to disable KeepAlive behavior for a connection and if yes how to do that. I would expect that it is possible by...
## Expected Behavior RSocketRequester and RSocketResponder should dispose of all associated resources when terminating. ## Actual Behavior RSocketRequester and RSocketResponder do not dispose of internal Flux subscriptions, creating a leak....
Fix #1050: Dispose of subscriptions in RSocketRequester and Responder ### Motivation: Properly dispose inner subscriptions when terminating a connection. ### Modifications: Calling `dispose` on `Disposable`. ### Result: No further Reactor...
When I report a issue, there's a prompt about 'Documentation issues' as reporting issues with the 'reference docs' or the 'api Java doc'. But as to the reference docs... I...
We request for a Maven Artifact to be published for the Rocket-Java.
```java var tcpClient = TcpClient.create() .host(serverHost) .port(serverPort); var proxyHost = rSocketClientProps.getProxyHost(); var proxyPort = rSocketClientProps.getProxyPort(); if (StringUtils.hasText(proxyHost)) { tcpClient=tcpClient.proxy(p -> p.type(ProxyProvider.Proxy.SOCKS5) .host(proxyHost) .port(proxyPort)); } log.info("[RSocketClient] connecting {}:{}", serverHost, serverPort); RSocketConnector.create()...
Add ability to mock an RSocket connection within unit tests to isolate functionality to one end of an RSocket connection for testing. ## Motivation Without the ability to mock an...
`RSocketClient` implements `Disposable` which provides a way to initiate a shutdown. However, there is no good way to hold for the result, and it is important in some cases to...
