missing nil check for grpc WaitGroup

sokolovstas · Jun 17, 2019 · 363fb55 · 363fb55
1 parent 7a87ae0
commit 363fb55
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/server/grpc/subscriber.go b/server/grpc/subscriber.go
@@ -231,9 +231,13 @@ func (g *grpcServer) createSubHandler(sb *subscriber, opts server.Options) broke
 				fn = opts.SubWrappers[i-1](fn)
 			}
 
-			g.wg.Add(1)
+			if g.wg != nil {
+				g.wg.Add(1)
+			}
 			go func() {
-				defer g.wg.Done()
+				if g.wg != nil {
+					defer g.wg.Done()
+				}
 				fn(ctx, &rpcMessage{
 					topic:       sb.topic,
 					contentType: ct,