Use new errgroup

This commit is contained in:
Nicholas Molnar 2022-05-16 10:08:39 -07:00 committed by Richard Ramos
parent 38fc9ee8bb
commit 5353ae48f2
1 changed files with 1 additions and 1 deletions

View File

@ -188,7 +188,7 @@ func (wf *WakuFilter) FilterListener() {
handle := func(envelope *protocol.Envelope) error { // async
msg := envelope.Message()
topic := envelope.PubsubTopic()
g, _ := errgroup.WithContext(context.Background())
g := new(errgroup.Group)
// Each subscriber is a light node that earlier on invoked
// a FilterRequest on this node
for subscriber := range wf.subscribers.Items() {