Unsubscribe from waku relay broadcaster

xmtp · Sep 12, 2023 · a8b7c19 · a8b7c19
1 parent 5ec6565
commit a8b7c19
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/server/server.go b/pkg/server/server.go
@@ -204,10 +204,12 @@ func New(ctx context.Context, log *zap.Logger, options Options) (*Server, error)
 	if !options.Relay.Disable {
 		for _, nodeTopic := range options.Relay.Topics {
 			nodeTopic := nodeTopic
-			_, err := s.wakuNode.Relay().SubscribeToTopic(s.ctx, nodeTopic)
+			sub, err := s.wakuNode.Relay().SubscribeToTopic(s.ctx, nodeTopic)
 			if err != nil {
 				return nil, errors.Wrap(err, "subscribing to pubsub topic")
 			}
+			// Unregister from broadcaster. Otherwise this channel will fill until it blocks publishing
+			sub.Unsubscribe()
 		}
 	}