diff --git a/protocol/streaming/full_node_streaming_manager.go b/protocol/streaming/full_node_streaming_manager.go index 57ea542e38..4c526a200b 100644 --- a/protocol/streaming/full_node_streaming_manager.go +++ b/protocol/streaming/full_node_streaming_manager.go @@ -29,6 +29,9 @@ type FullNodeStreamingManagerImpl struct { ticker *time.Ticker done chan bool + // TODO: Consolidate the streamUpdateCache and streamUpdateSubscriptionCache into a single + // struct to avoid the need to maintain two separate slices for the same data. + // list of stream updates. streamUpdateCache []clobtypes.StreamUpdate // list of subscription ids for each stream update.