We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1595288 commit f4ed1f1Copy full SHA for f4ed1f1
rsocket-core/src/main/java/io/rsocket/frame/decoder/ZeroCopyPayloadDecoder.java
@@ -15,22 +15,6 @@
15
*/
16
public class ZeroCopyPayloadDecoder implements PayloadDecoder {
17
18
- static {
19
- Hooks.onNextDropped(
20
- o -> {
21
- if (o instanceof ReferenceCounted) {
22
- ReferenceCounted referenceCounted = (ReferenceCounted) o;
23
- if (referenceCounted.refCnt() > 0) {
24
- try {
25
- referenceCounted.release();
26
- } catch (IllegalReferenceCountException e) {
27
- // ignored
28
- }
29
30
31
- });
32
33
-
34
@Override
35
public Payload apply(ByteBuf byteBuf) {
36
ByteBuf m;
0 commit comments