From a9a64c862e8f4d1ff9bd371e164dd65968a5f67d Mon Sep 17 00:00:00 2001 From: nick Date: Thu, 11 Jul 2024 12:00:19 +0900 Subject: [PATCH] fix: remove unnecessary encapsulation --- node/pkg/dal/collector/collector.go | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/node/pkg/dal/collector/collector.go b/node/pkg/dal/collector/collector.go index 67b00f01c..0e005c53b 100644 --- a/node/pkg/dal/collector/collector.go +++ b/node/pkg/dal/collector/collector.go @@ -164,7 +164,7 @@ func (c *Collector) processIncomingData(ctx context.Context, data aggregator.Sub log.Error().Err(err).Str("Player", "DalCollector").Msg("failed to convert incoming data to outgoing data") return } - defer c.storeLatest(result) + defer c.LatestData.Store(result.Symbol, result) c.OutgoingStream[data.GlobalAggregate.ConfigID] <- *result } @@ -226,7 +226,3 @@ func (c *Collector) trackOracleAdded(ctx context.Context) { } }() } - -func (c *Collector) storeLatest(data *dalcommon.OutgoingSubmissionData) { - c.LatestData.Store(data.Symbol, data) -}