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 24691af commit ad372daCopy full SHA for ad372da
rsocket-core/src/main/java/io/rsocket/util/ByteBufPayload.java
@@ -159,6 +159,7 @@ public static Payload create(ByteBuf data) {
159
160
public static Payload create(ByteBuf data, @Nullable ByteBuf metadata) {
161
ByteBufPayload payload = RECYCLER.get();
162
+ payload.setRefCnt(1);
163
payload.data = data;
164
payload.metadata = metadata;
165
return payload;
0 commit comments