feat: unblock receive func

Bisonai · Aug 9, 2024 · 1de81dc · 1de81dc
1 parent e42b64e
commit 1de81dc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/node/pkg/dal/collector/collector.go b/node/pkg/dal/collector/collector.go
@@ -169,10 +169,10 @@ func (c *Collector) Stop() {
 }
 
 func (c *Collector) receive(ctx context.Context) {
-	c.baseRediscribe.Start(ctx)
+	go c.baseRediscribe.Start(ctx)
 
 	if c.subRediscribe != nil {
-		c.subRediscribe.Start(ctx)
+		go c.subRediscribe.Start(ctx)
 	}
 }