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()