rsocket-java

rsocket-java copied to clipboard

Ability to store session object inside RSocketRequester chain

1

Hello. Would be very nice to add to somewhere inside `RSocketRequester` the `AtomicReference` type field that will cache the session object for reuse, especially it will be very convenient to...

maxim-bandurko-lsvt

1.1.4 Regression - RejectedSetupException on auth failure results in ClosedChannelException

4

RSocket server can do connection-level authentication checks via `socketAcceptor` interceptors. An interceptor can check for valid authentication in the setup payload and decide whether to forward the accept the connection,...

mdindoffer

I tried throwing an exception in the errorConsumer on the server, so that the client's request seems to not be released, and will not do doOnComplete() and map() ## Expected...

levil3

Signed-off-by: kevin

kevinat

I'm getting some warnings about memory leaks with Spring boot 3.2, and after searching I found that according to: [Netty reports LEAK while using reactor (Rsocket) with Sleuth #2256](https://github.com/spring-cloud/spring-cloud-sleuth/issues/2256) there...

kevinat

Rsocket error "java.lang.IllegalStateException: Source has to be ASYNC fuseable" with Spring boot 3.2.x & JDK17

4

## Expected Behavior The Rocket server should respond to the client. `Hello from RSocket consumer` ## Actual Behavior Throwing exception reactor.core.Exceptions$ErrorCallbackNotImplemented: java.lang.IllegalStateException: Source has to be ASYNC fuseable **Error stack...

abdulrahimseera

Using the server setup found [here](https://github.com/rsocket/rsocket-java/issues/987#issuecomment-796176003) and using rsocket-core 1.1.3 my server behaves as expected. If for some reason no acks get delivered during the keep-alive timeout it will restart...

pstreef

## Documentation Issue https://rsocket.io/about/implementations says that resumption isn't supported for `rsocket-java`. However, from searching through the issues it looks like it is supported. ## Improvement Suggestion Add the `X` in...

leonard84

How to keep RSocket connection alive forever. What should be configuration values for keepalive(interval, maxLifeTime) to achieve this?

2

I am using RSocket for client server communications, here expecting connection to be alive until closed manually. Its like starting a subscription from client to Server, where client and server...

sudhanshucs0102

I have two rsocket-client and one rsocket-server. Both rsocket-client initially subscribe to the broadcast route listenCommand to receive commands from rsocket-server. Then one of the clients sends a command on...

TashaBond