This commit is contained in:
iamqizhao 2015-10-02 14:26:13 -07:00
commit bd2da124cc
1 changed files with 2 additions and 5 deletions

View File

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