From 457459b57001c7aace17b4467ee8c078996fa82a Mon Sep 17 00:00:00 2001 From: Matthew Weeks Date: Fri, 10 Jan 2025 14:14:13 -0500 Subject: [PATCH] Set filteredUpdateChannel size to maxSubscriptionChannelSize --- protocol/streaming/full_node_streaming_manager.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/protocol/streaming/full_node_streaming_manager.go b/protocol/streaming/full_node_streaming_manager.go index be7962f230..24354a3061 100644 --- a/protocol/streaming/full_node_streaming_manager.go +++ b/protocol/streaming/full_node_streaming_manager.go @@ -358,7 +358,7 @@ func (sm *FullNodeStreamingManagerImpl) Subscribe( ), ) } else { - filteredUpdateChannel = make(chan []clobtypes.StreamUpdate) + filteredUpdateChannel = make(chan []clobtypes.StreamUpdate, sm.maxSubscriptionChannelSize) defer close(filteredUpdateChannel) go subscription.FilterSubaccountStreamUpdates(filteredUpdateChannel, sm.logger) }