From 5353ae48f2fa34732cae2317ac68a63cc4f0cb4f Mon Sep 17 00:00:00 2001 From: Nicholas Molnar Date: Mon, 16 May 2022 10:08:39 -0700 Subject: [PATCH] Use new errgroup --- waku/v2/protocol/filter/waku_filter.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/waku/v2/protocol/filter/waku_filter.go b/waku/v2/protocol/filter/waku_filter.go index 095efc1c..001ff34b 100644 --- a/waku/v2/protocol/filter/waku_filter.go +++ b/waku/v2/protocol/filter/waku_filter.go @@ -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() {