From d24eeed508cf9a29cba510bffe30506ab62eddcc Mon Sep 17 00:00:00 2001 From: nick Date: Tue, 30 Jul 2024 17:38:15 +0900 Subject: [PATCH] feat: update buffer --- node/pkg/dal/collector/collector.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/node/pkg/dal/collector/collector.go b/node/pkg/dal/collector/collector.go index 16d2f4819..58d6edb8f 100644 --- 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)) }