Set refCnt back to 1 when recycling ByteBufPayload (#446)

rsocket · Nov 14, 2017 · ad372da · ad372da
1 parent 24691af
commit ad372da
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/rsocket-core/src/main/java/io/rsocket/util/ByteBufPayload.java b/rsocket-core/src/main/java/io/rsocket/util/ByteBufPayload.java
@@ -159,6 +159,7 @@ public static Payload create(ByteBuf data) {
 
   public static Payload create(ByteBuf data, @Nullable ByteBuf metadata) {
     ByteBufPayload payload = RECYCLER.get();
+    payload.setRefCnt(1);
     payload.data = data;
     payload.metadata = metadata;
     return payload;