rsocket-java
rsocket-java copied to clipboard
rsocket
Java implementation of RSocket
My use case revolves around retrieving the data from Cassandra using RSocket-Java in a non-blocking way. I use reactive cassandra template built on top of reactor-core. Throughput I see is...
Trying to troubleshoot some issues, support to export Reactor metrics to Grafana was added. To my surprise, the queue was always filled with tasks, even if nothing much happened in...
Payload API has inconsistent and absolutely confusing behavior: ##Expected case 1 ``` var p = ByteBufPayload.create(data, Unpooled.EMPTY) assertTrue(p.hasMetadata()) assertEqueals(p.metadata(), Unpooled.EMPTY) ``` ## Unexpected case 2 ``` var p = ByteBufPayload.create(data,...
RSocket spec supports Extension frames: https://github.com/rsocket/rsocket/blob/master/Protocol.md#frame-ext Add a way to handle extension frames
Rate limiting has been through a few iterations starting with the original `LimitableRequestPublisher` that actually imposed no upper limit and was exposed to issues like #514, later replaced by `RateLimitableRequestPublisher`...
When outgoing messages queue grows, responses are likely to timeout before respective request frame is even sent - causing unnecessary work on responder side. New requests have no chance to...
I have done some research on the performance of RSocket vs HTTP for a service-to-service communication of [FHIR](http://hl7.org/implement/standards/fhir/) resources. According to the initial results, the RSocket performance seems to be...
[Lease frames](https://rsocket.io/about/protocol#lease-semantics) allow a responder to control the total number of requests from the other end, but it is an optional feature, and there should also be a way to...
## Motivation I have been evaluating the RSocket and did some profiling. It looks like creating Frame message many `ByteBuf` buffers are used (i.e. header, payload, frame size). Those buffers...
