Skip to content

Commit

Permalink
Fix comments
Browse files Browse the repository at this point in the history
  • Loading branch information
tmdiep committed Dec 2, 2020
1 parent e2472bc commit 64f7469
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions pubsublite/ps/settings.go
Expand Up @@ -119,7 +119,8 @@ 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 terminate once all outstanding message receivers have
// finished and outstanding messages have been ack or nacked.
//
// 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
Expand Down Expand Up @@ -160,8 +161,7 @@ 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.
NackHandler NackHandler

// Optional custom function that transforms a PubSubMessage API proto to a
Expand Down

0 comments on commit 64f7469

Please sign in to comment.