Specificity in comment

snowplow · Nov 12, 2024 · 71ede8c · 71ede8c
1 parent b866b5a
commit 71ede8c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/source/pubsub/pubsub_source.go b/pkg/source/pubsub/pubsub_source.go
@@ -171,7 +171,7 @@ func (ps *pubSubSource) Read(sf *sourceiface.SourceFunctions) error {
 
 	sub := ps.client.Subscription(ps.subscriptionID)
 	sub.ReceiveSettings.NumGoroutines = ps.streamingPullGoRoutines         // This sets the number of goroutines that can open a streaming pull at once
-	sub.ReceiveSettings.MaxOutstandingMessages = ps.maxOutstandingMessages // maxOutstandingMessages limits the number of messages processed at once
+	sub.ReceiveSettings.MaxOutstandingMessages = ps.maxOutstandingMessages // maxOutstandingMessages limits the number of messages processed at once (each spawns a goroutine)
 	sub.ReceiveSettings.MaxOutstandingBytes = ps.maxOutstandingBytes
 	sub.ReceiveSettings.MinExtensionPeriod = time.Duration(ps.minExtensionPeriodSeconds) * time.Second