Skip to content

Commit e45f9d2

Browse files
authored
Feature/framing (#575)
* Adds specific requestChannel(Payload, Publisher<Payload>) (#572) * optimize request channel to let you peak at the first item in the requestChannel Signed-off-by: Robert Roeser <[email protected]> * updated javadoc Signed-off-by: Robert Roeser <[email protected]> * updates Signed-off-by: Robert Roeser <[email protected]> * call requestChannelWith 2 arguments Signed-off-by: Robert Roeser <[email protected]> Signed-off-by: Robert Roeser <[email protected]> * first pass at refactoring to idomatic ByteBuf flyweights Signed-off-by: Robert Roeser <[email protected]> * fixing tests Signed-off-by: Robert Roeser <[email protected]> * fixed some more tests Signed-off-by: Robert Roeser <[email protected]> * fix frame flyweights Signed-off-by: Robert Roeser <[email protected]> * testing Signed-off-by: Robert Roeser <[email protected]> * accept ByteBufAllocator in a constructors and renames FrameDecoder to PayloadDecoder Signed-off-by: Robert Roeser <[email protected]> * javadoc Signed-off-by: Robert Roeser <[email protected]> * first pass at refactoring to idomatic ByteBuf flyweights Signed-off-by: Robert Roeser <[email protected]> * fixing tests Signed-off-by: Robert Roeser <[email protected]> * fixed some more tests Signed-off-by: Robert Roeser <[email protected]> * testing Signed-off-by: Robert Roeser <[email protected]> * fix frame flyweights Signed-off-by: Robert Roeser <[email protected]> * accept ByteBufAllocator in a constructors and renames FrameDecoder to PayloadDecoder Signed-off-by: Robert Roeser <[email protected]> * javadoc Signed-off-by: Robert Roeser <[email protected]> * setup frame flyweight: allow null metadata restore micrometer RSocket test Signed-off-by: Maksym Ostroverkhov <[email protected]> * apply fixes from review release ByteBufs in tests Signed-off-by: Maksym Ostroverkhov <[email protected]>
1 parent 21c39bd commit e45f9d2

File tree

172 files changed

+2803
-12145
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

172 files changed

+2803
-12145
lines changed

README.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ public class ExampleClient {
8282

8383
## Zero Copy
8484
By default to make RSocket easier to use it copies the incoming Payload. Copying the payload comes at cost to performance
85-
and latency. If you want to use zero copy you must disable this. To disable copying you must include a `frameDecoder`
85+
and latency. If you want to use zero copy you must disable this. To disable copying you must include a `payloadDecoder`
8686
argument in your `RSocketFactory`. This will let you manage the Payload without copying the data from the underlying
8787
transport. You must free the Payload when you are done with them
8888
or you will get a memory leak. Used correctly this will reduce latency and increase performance.
@@ -91,7 +91,7 @@ or you will get a memory leak. Used correctly this will reduce latency and incre
9191
```java
9292
RSocketFactory.receive()
9393
// Enable Zero Copy
94-
.frameDecoder(Frame::retain)
94+
.payloadDecoder(Frame::retain)
9595
.acceptor(new PingHandler())
9696
.transport(TcpServerTransport.create(7878))
9797
.start()
@@ -105,7 +105,7 @@ RSocketFactory.receive()
105105
Mono<RSocket> client =
106106
RSocketFactory.connect()
107107
// Enable Zero Copy
108-
.frameDecoder(Frame::retain)
108+
.payloadDecoder(Frame::retain)
109109
.transport(TcpClientTransport.create(7878))
110110
.start();
111111
```

rsocket-core/src/jmh/java/io/rsocket/RSocketPerf.java

Lines changed: 0 additions & 199 deletions
This file was deleted.

rsocket-core/src/jmh/java/io/rsocket/fragmentation/FragmentationPerformanceTest.java

Lines changed: 0 additions & 152 deletions
This file was deleted.

0 commit comments

Comments
 (0)