fixes test

Signed-off-by: Oleh Dokuka <shadowgun@i.ua>
rsocket · Mar 8, 2020 · d3915b7 · d3915b7
1 parent c6cf8eb
commit d3915b7
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/rsocket-core/src/main/java/io/rsocket/util/CharByteBufUtil.java b/rsocket-core/src/main/java/io/rsocket/util/CharByteBufUtil.java
@@ -182,7 +182,10 @@ public static char[] readUtf8(ByteBuf byteBuf, int length) {
     char[] ca = new char[en];
 
     CharBuffer charBuffer = CharBuffer.wrap(ca);
-    ByteBuffer byteBuffer = byteBuf.internalNioBuffer(byteBuf.readerIndex(), length);
+    ByteBuffer byteBuffer =
+        byteBuf.nioBufferCount() == 1
+            ? byteBuf.internalNioBuffer(byteBuf.readerIndex(), length)
+            : byteBuf.nioBuffer(byteBuf.readerIndex(), length);
     byteBuffer.mark();
     try {
       CoderResult cr = charsetDecoder.decode(byteBuffer, charBuffer, true);