grpc
/
grpc-go
mirror of https://github.com/grpc/grpc-go.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #384 from mwitkow-io/bugfix/fix_stream_codec_errors_take2 

fix difference between unitary and stream codec error handling
This commit is contained in:
Qi Zhao 2015-10-06 15:58:37 -07:00
parent c2ad501830 1a7cf7f696
commit 4673c7de99
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
rpc_util.go
View File

@ -187,7 +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.")