Add support for method return ByteBuf

zhou-hao · web-flow · commit 50b1efb3f288 · 2022-06-08T13:49:59.000+08:00
diff --git a/services-bytebuf-codec/src/main/java/io/scalecube/services/transport/api/ServiceMessageCodec.java b/services-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;
     }
 

Original file line number	Diff line number	Diff line change
`@@ -157,7 +157,8 @@ public static ServiceMessage decodeData(ServiceMessage message, Type dataType)`
`157`	`157`	`throws MessageCodecException {`
`158`	`158`	`if (dataType == null`
`159`	`159`	`\|\| !message.hasData(ByteBuf.class)`
`160`		`- \|\| ((ByteBuf) message.data()).readableBytes() == 0) {`
	`160`	`+ \|\| ((ByteBuf) message.data()).readableBytes() == 0`
	`161`	`+ \|\| ByteBuf.class == dataType) {`
`161`	`162`	`return message;`
`162`	`163`	`}`
`163`	`164`