Copy ReceiveSettings.Partitions

googleapis · Nov 27, 2020 · dd148f6 · dd148f6
1 parent 02bc46e
commit dd148f6
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pubsublite/ps/settings.go b/pubsublite/ps/settings.go
@@ -180,6 +180,7 @@ func (s *ReceiveSettings) toWireSettings() wire.ReceiveSettings {
 		MaxOutstandingMessages: s.MaxOutstandingMessages,
 		MaxOutstandingBytes:    s.MaxOutstandingBytes,
 		Timeout:                s.Timeout,
+		Partitions:             s.Partitions,
 		Framework:              wire.FrameworkCloudPubSubShim,
 	}
 }