go/go-micro
1
0
Fork 0
mirror of https://github.com/go-micro/go-micro.git synced 2025-07-12 22:41:07 +02:00
Code Issues Releases Activity

Merge pull request #519 from xpunch/master

Browse Source 
missing nil check for grpc WaitGroup
This commit is contained in:
Asim Aslam
2019-06-17 10:30:28 +01:00
committed by GitHub
parent 7a87ae0efa 363fb551af
commit a619321b64
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/grpc/subscriber.go
View File

@ -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,