feat: update buffer

Bisonai · Jul 30, 2024 · d24eeed · d24eeed
1 parent 2c5ec0f
commit d24eeed
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
@@ -76,8 +76,8 @@ func NewCollector(ctx context.Context, configs []types.Config) (*Collector, erro
 	}
 
 	for _, config := range configs {
-		collector.IncomingStream[config.ID] = make(chan aggregator.SubmissionData)
-		collector.OutgoingStream[config.ID] = make(chan dalcommon.OutgoingSubmissionData)
+		collector.IncomingStream[config.ID] = make(chan aggregator.SubmissionData, 1000)
+		collector.OutgoingStream[config.ID] = make(chan dalcommon.OutgoingSubmissionData, 1000)
 		collector.Symbols[config.ID] = config.Name
 		collector.FeedHashes[config.ID] = crypto.Keccak256([]byte(config.Name))
 	}