diff --git a/server/rpc_server.go b/server/rpc_server.go index 48fd97c1..6b6af066 100644 --- a/server/rpc_server.go +++ b/server/rpc_server.go @@ -46,7 +46,6 @@ func newRpcServer(opts ...Option) Server { handlers: make(map[string]Handler), subscribers: make(map[*subscriber][]broker.Subscriber), exit: make(chan chan error), - wg: sync.WaitGroup{}, } }