This commit is contained in:
iamqizhao
2015-10-02 13:30:47 -07:00

View File

@ -187,8 +187,11 @@ func recv(p *parser, c Codec, m interface{}) error {
switch pf { switch pf {
case compressionNone: case compressionNone:
if err := c.Unmarshal(d, m); err != nil { if err := c.Unmarshal(d, m); err != nil {
return Errorf(codes.Internal, "grpc: %v", err) if rErr, ok := err.(rpcError); ok {
} return rErr
} else {
return Errorf(codes.Internal, "grpc: %v", err)
}
default: default:
return Errorf(codes.Internal, "gprc: compression is not supported yet.") return Errorf(codes.Internal, "gprc: compression is not supported yet.")
} }