Skip to content
Snippets Groups Projects
Commit d3667059 authored by haohongfan's avatar haohongfan
Browse files

feat: format DubboCodec

parent 48d746fc
No related branches found
No related tags found
No related merge requests found
......@@ -167,13 +167,13 @@ func (c *DubboCodec) Decode(data []byte) (remoting.DecodeResult, int, error) {
return remoting.DecodeResult{}, len, perrors.WithStack(err)
}
return remoting.DecodeResult{IsRequest: true, Result: req}, len, perrors.WithStack(err)
} else {
resp, len, err := c.decodeResponse(data)
if err != nil {
return remoting.DecodeResult{}, len, perrors.WithStack(err)
}
return remoting.DecodeResult{IsRequest: false, Result: resp}, len, perrors.WithStack(err)
}
resp, len, err := c.decodeResponse(data)
if err != nil {
return remoting.DecodeResult{}, len, perrors.WithStack(err)
}
return remoting.DecodeResult{IsRequest: false, Result: resp}, len, perrors.WithStack(err)
}
func (c *DubboCodec) isRequest(data []byte) bool {
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment