Set filteredUpdateChannel size to maxSubscriptionChannelSize

dydxprotocol · Jan 10, 2025 · 457459b · 457459b
1 parent 97d08ce
commit 457459b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
 		}