use heap buffers in the default payload decoder (#945)

rsocket · Oct 13, 2020 · 088cad9 · 088cad9
1 parent 4e379f1
commit 088cad9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/rsocket-core/src/main/java/io/rsocket/frame/decoder/DefaultPayloadDecoder.java b/rsocket-core/src/main/java/io/rsocket/frame/decoder/DefaultPayloadDecoder.java
@@ -52,12 +52,12 @@ public Payload apply(ByteBuf byteBuf) {
         throw new IllegalArgumentException("unsupported frame type: " + type);
     }
 
-    ByteBuffer data = ByteBuffer.allocateDirect(d.readableBytes());
+    ByteBuffer data = ByteBuffer.allocate(d.readableBytes());
     data.put(d.nioBuffer());
     data.flip();
 
     if (m != null) {
-      ByteBuffer metadata = ByteBuffer.allocateDirect(m.readableBytes());
+      ByteBuffer metadata = ByteBuffer.allocate(m.readableBytes());
       metadata.put(m.nioBuffer());
       metadata.flip();