We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 90825bf commit 7eaaa25Copy full SHA for 7eaaa25
1 file changed
rocketmq-remoting/src/rpc/rpc_client_utils.rs
@@ -54,8 +54,8 @@ impl RpcClientUtils {
54
// None
55
// } else if let Some(bytes) = body.downcast_ref::<Bytes>() {
56
// Ok(Some(bytes.clone()))
57
- // } else if let Some(remoting_serializable) = body.downcast_ref::<&dyn RemotingSerializable>()
58
- // {
+ // } else if let Some(remoting_serializable) = body.downcast_ref::<&dyn
+ // RemotingSerializable>() {
59
// Ok(Some(Bytes::from(*remoting_serializable.encode())))
60
// } else if let Some(buffer) = body.downcast_ref::<BytesMut>() {
61
// let data = buffer.clone().freeze();
0 commit comments