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)
 		}