diff options
Diffstat (limited to 'vendor/github.com/grpc-ecosystem/go-grpc-middleware/chain.go')
| -rw-r--r-- | vendor/github.com/grpc-ecosystem/go-grpc-middleware/chain.go | 16 |
1 files changed, 4 insertions, 12 deletions
diff --git a/vendor/github.com/grpc-ecosystem/go-grpc-middleware/chain.go b/vendor/github.com/grpc-ecosystem/go-grpc-middleware/chain.go index 45a2f5f49..7e82a081c 100644 --- a/vendor/github.com/grpc-ecosystem/go-grpc-middleware/chain.go +++ b/vendor/github.com/grpc-ecosystem/go-grpc-middleware/chain.go @@ -31,9 +31,7 @@ func ChainUnaryServer(interceptors ...grpc.UnaryServerInterceptor) grpc.UnarySer return handler(currentCtx, currentReq) } curI++ - resp, err := interceptors[curI](currentCtx, currentReq, info, chainHandler) - curI-- - return resp, err + return interceptors[curI](currentCtx, currentReq, info, chainHandler) } return interceptors[0](ctx, req, info, chainHandler) @@ -71,9 +69,7 @@ func ChainStreamServer(interceptors ...grpc.StreamServerInterceptor) grpc.Stream return handler(currentSrv, currentStream) } curI++ - err := interceptors[curI](currentSrv, currentStream, info, chainHandler) - curI-- - return err + return interceptors[curI](currentSrv, currentStream, info, chainHandler) } return interceptors[0](srv, stream, info, chainHandler) @@ -110,9 +106,7 @@ func ChainUnaryClient(interceptors ...grpc.UnaryClientInterceptor) grpc.UnaryCli return invoker(currentCtx, currentMethod, currentReq, currentRepl, currentConn, currentOpts...) } curI++ - err := interceptors[curI](currentCtx, currentMethod, currentReq, currentRepl, currentConn, chainHandler, currentOpts...) - curI-- - return err + return interceptors[curI](currentCtx, currentMethod, currentReq, currentRepl, currentConn, chainHandler, currentOpts...) } return interceptors[0](ctx, method, req, reply, cc, chainHandler, opts...) @@ -149,9 +143,7 @@ func ChainStreamClient(interceptors ...grpc.StreamClientInterceptor) grpc.Stream return streamer(currentCtx, currentDesc, currentConn, currentMethod, currentOpts...) } curI++ - stream, err := interceptors[curI](currentCtx, currentDesc, currentConn, currentMethod, chainHandler, currentOpts...) - curI-- - return stream, err + return interceptors[curI](currentCtx, currentDesc, currentConn, currentMethod, chainHandler, currentOpts...) } return interceptors[0](ctx, desc, cc, method, chainHandler, opts...) |