diff --git a/protocol/streaming/full_node_streaming_manager.go b/protocol/streaming/full_node_streaming_manager.go index c826b0ceed..99d3452d5e 100644 --- a/protocol/streaming/full_node_streaming_manager.go +++ b/protocol/streaming/full_node_streaming_manager.go @@ -30,6 +30,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.