From bf8c856bc36e0cc72a47697cdb2a6f540ee96588 Mon Sep 17 00:00:00 2001 From: harsh-98 Date: Fri, 5 May 2023 20:35:44 +0530 Subject: [PATCH] fix: use buffered channel as needed by legacy_filter, filter --- waku/v2/protocol/relay/waku_relay.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/waku/v2/protocol/relay/waku_relay.go b/waku/v2/protocol/relay/waku_relay.go index 4dcad0d7..3eb9bc5c 100644 --- a/waku/v2/protocol/relay/waku_relay.go +++ b/waku/v2/protocol/relay/waku_relay.go @@ -270,7 +270,7 @@ func (w *WakuRelay) SubscribeToTopic(ctx context.Context, topic string) (*Subscr // Create client subscription subscription := NoopSubscription() if w.bcaster != nil { - subscription = w.bcaster.Register(topic) + subscription = w.bcaster.Register(topic, 1024) } go func() { <-ctx.Done()