named return value for error defer modify.

2019-12-09 11:08:21 +08:00
parent e2b2a30668
commit caa1bcf9fe
3 changed files with 3 additions and 6 deletions
--- a/server/grpc/subscriber.go
+++ b/server/grpc/subscriber.go
@@ -167,8 +167,7 @@ func validateSubscriber(sub server.Subscriber) error {
 }

 func (g *grpcServer) createSubHandler(sb *subscriber, opts server.Options) broker.Handler {
-	return func(p broker.Event) error {
-		var err error
+	return func(p broker.Event) (err error) {

 		defer func() {
 			if r := recover(); r != nil {