rsocket-java
rsocket-java copied to clipboard
rsocket
Java implementation of RSocket
Add Rsocket Object supports get local address and remote address Motivation: It is convenient for business system to obtain local address and remote address from rsocket object Modifications: Modify the...
After upgrading to 1.0.2 version Resume functionality cause stuck client waiting to answer forever At 1.0.1 all worked as expected.Also if I remove resume code all work as expected. I...
Currently, RSocket follows Netty style of managing refCnt which is somewhat challenging (and not necessarily needed to be like in pure Netty). Therefore, I would like to propose redesign that...
The **readme** states that Aeron is available for use, however from looking at the [issues](https://github.com/rsocket/rsocket-java/issues/309) and at [stackoverflow](https://stackoverflow.com/questions/50061488/how-do-i-create-a-file-sending-client-server-with-rsocket), the comment `I wouldn't recommend using the Aeron implementation currently.` bothers me....
Currently it's hard to tell how quickly or slowly a given stream is emitting data. Timing between start and a terminal signal doesn't tell that (which is why we don't...
`RSocketConnector` and `RSocketServer` can be configured with a `SocketAcceptor` that handles all requests. A framework can build on this low level mechanism and decide how to route requests internally. However...
## The Problem Right now in RSocket we use `UnboundedProcessor` which simply is an `MultiProducerSingleConsumerArrayLinkedQueue`. It means that all frames from all possible interactions are enqueued into that queue with...
As of now `DuplexConnecton` has a pretty straightforward mechanism for sending frames, however, it may be useful in many cases to follow the connection level backpressure so the sender will...