Commit e45f9d2
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 <rroeserr@gmail.com>
* updated javadoc
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* updates
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* call requestChannelWith 2 arguments
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* first pass at refactoring to idomatic ByteBuf flyweights
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* fixing tests
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* fixed some more tests
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* fix frame flyweights
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* testing
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* accept ByteBufAllocator in a constructors and renames FrameDecoder to PayloadDecoder
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* javadoc
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* first pass at refactoring to idomatic ByteBuf flyweights
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* fixing tests
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* fixed some more tests
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* testing
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* fix frame flyweights
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* accept ByteBufAllocator in a constructors and renames FrameDecoder to PayloadDecoder
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* javadoc
Signed-off-by: Robert Roeser <rroeserr@gmail.com>
* setup frame flyweight: allow null metadata
restore micrometer RSocket test
Signed-off-by: Maksym Ostroverkhov <m.ostroverkhov@gmail.com>
* apply fixes from review
release ByteBufs in tests
Signed-off-by: Maksym Ostroverkhov <m.ostroverkhov@gmail.com>1 parent 21c39bd commit e45f9d2
File tree
172 files changed
+2803
-12145
lines changed- rsocket-core/src
- jmh/java/io/rsocket
- fragmentation
- frame
- perfutil
- main/java/io/rsocket
- exceptions
- fragmentation
- frame
- decoder
- framing
- internal
- lease
- resume
- util
- test
- java/io/rsocket
- exceptions
- fragmentation
- frame
- old
- framing
- internal
- resume
- test/util
- util
- resources/META-INF/services
- rsocket-micrometer/src
- main/java/io/rsocket/micrometer
- test/java/io/rsocket/micrometer
- rsocket-test/src/main/java/io/rsocket/test
- rsocket-transport-local/src
- main/java/io/rsocket/transport/local
- test
- java/io/rsocket/transport/local
- resources
- rsocket-transport-netty/src
- main/java/io/rsocket/transport/netty
- test/java/io/rsocket/transport/netty
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| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
82 | 82 | | |
83 | 83 | | |
84 | 84 | | |
85 | | - | |
| 85 | + | |
86 | 86 | | |
87 | 87 | | |
88 | 88 | | |
| |||
91 | 91 | | |
92 | 92 | | |
93 | 93 | | |
94 | | - | |
| 94 | + | |
95 | 95 | | |
96 | 96 | | |
97 | 97 | | |
| |||
105 | 105 | | |
106 | 106 | | |
107 | 107 | | |
108 | | - | |
| 108 | + | |
109 | 109 | | |
110 | 110 | | |
111 | 111 | | |
| |||
This file was deleted.
Lines changed: 0 additions & 152 deletions
This file was deleted.
0 commit comments