diff --git a/pubsublite/ps/settings.go b/pubsublite/ps/settings.go index 1b518639669c..583adc723d28 100644 --- a/pubsublite/ps/settings.go +++ b/pubsublite/ps/settings.go @@ -119,7 +119,7 @@ func (s *PublishSettings) toWireSettings() wire.PublishSettings { // NackHandler is invoked when pubsub.Message.Nack() is called. Cloud Pub/Sub // Lite does not have a concept of 'nack'. If the nack handler implementation // returns nil, the message is acknowledged. If an error is returned, the -// SubscriberClient will will consider this a fatal error and terminate. +// SubscriberClient will consider this a fatal error and terminate. // // In Cloud Pub/Sub Lite, only a single subscriber for a given subscription is // connected to any partition at a time, and there is no other client that may @@ -160,8 +160,8 @@ type ReceiveSettings struct { Partitions []int // Optional custom function to handle pubsub.Message.Nack() calls. If not set, - // the default behavior is to immediately terminate the SubscriberClient with - // a fatal error. + // the default behavior is to terminate the SubscriberClient with a fatal + // error. NackHandler NackHandler // Optional custom function that transforms a PubSubMessage API proto to a