Merge pull request #827 from zhou-hao/patch-1

Add support for method return ByteBuf
scalecube · Oct 1, 2022 · 65c6f84 · 65c6f84
2 parents f6b9683 + 50b1efb
commit 65c6f84
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...-bytebuf-codec/src/main/java/io/scalecube/services/transport/api/ServiceMessageCodec.java b/...-bytebuf-codec/src/main/java/io/scalecube/services/transport/api/ServiceMessageCodec.java
@@ -157,7 +157,8 @@ public static ServiceMessage decodeData(ServiceMessage message, Type dataType)
       throws MessageCodecException {
     if (dataType == null
         || !message.hasData(ByteBuf.class)
-        || ((ByteBuf) message.data()).readableBytes() == 0) {
+        || ((ByteBuf) message.data()).readableBytes() == 0
+        || ByteBuf.class == dataType) {
       return message;
     }