Skip to content

Commit

Permalink
fix: remove unnecessary encapsulation
Browse files Browse the repository at this point in the history
  • Loading branch information
nick-bisonai committed Jul 11, 2024
1 parent 597fbd7 commit c61c9a9
Showing 1 changed file with 1 addition and 5 deletions.
6 changes: 1 addition & 5 deletions node/pkg/dal/collector/collector.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
}

Expand Down Expand Up @@ -226,7 +226,3 @@ func (c *Collector) trackOracleAdded(ctx context.Context) {
}
}()
}

func (c *Collector) storeLatest(data *dalcommon.OutgoingSubmissionData) {
c.LatestData.Store(data.Symbol, data)
}

0 comments on commit c61c9a9

Please sign in to comment.