Minor change to examples for consistency

googleapis · Dec 23, 2020 · a33a81e · a33a81e
1 parent 4fbb3a1
commit a33a81e
Showing 1 changed file with 24 additions and 8 deletions.
diff --git a/pubsublite/ps/example_test.go b/pubsublite/ps/example_test.go
@@ -24,7 +24,11 @@ import (
 
 func ExamplePublisherClient_Publish() {
 	ctx := context.Background()
-	topic := pubsublite.TopicPath{Project: "project-id", Zone: "zone", TopicID: "topic-id"}
+	topic := pubsublite.TopicPath{
+		Project: "project-id",
+		Zone:    "zone",
+		TopicID: "topic-id",
+	}
 	publisher, err := ps.NewPublisherClient(ctx, ps.DefaultPublishSettings, topic)
 	if err != nil {
 		// TODO: Handle error.
@@ -48,7 +52,11 @@ func ExamplePublisherClient_Publish() {
 
 func ExamplePublisherClient_Error() {
 	ctx := context.Background()
-	topic := pubsublite.TopicPath{Project: "project-id", Zone: "zone", TopicID: "topic-id"}
+	topic := pubsublite.TopicPath{
+		Project: "project-id",
+		Zone:    "zone",
+		TopicID: "topic-id",
+	}
 	publisher, err := ps.NewPublisherClient(ctx, ps.DefaultPublishSettings, topic)
 	if err != nil {
 		// TODO: Handle error.
@@ -75,13 +83,17 @@ func ExamplePublisherClient_Error() {
 
 func ExampleSubscriberClient_Receive() {
 	ctx := context.Background()
-	subscription := pubsublite.SubscriptionPath{Project: "project-id", Zone: "zone", SubscriptionID: "subscription-id"}
-	sub, err := ps.NewSubscriberClient(ctx, ps.DefaultReceiveSettings, subscription)
+	subscription := pubsublite.SubscriptionPath{
+		Project:        "project-id",
+		Zone:           "zone",
+		SubscriptionID: "subscription-id",
+	}
+	subscriber, err := ps.NewSubscriberClient(ctx, ps.DefaultReceiveSettings, subscription)
 	if err != nil {
 		// TODO: Handle error.
 	}
 	cctx, cancel := context.WithCancel(ctx)
-	err = sub.Receive(cctx, func(ctx context.Context, m *pubsub.Message) {
+	err = subscriber.Receive(cctx, func(ctx context.Context, m *pubsub.Message) {
 		// TODO: Handle message.
 		// NOTE: May be called concurrently; synchronize access to shared memory.
 		m.Ack()
@@ -101,16 +113,20 @@ func ExampleSubscriberClient_Receive() {
 // partitions in the associated topic.
 func ExampleSubscriberClient_Receive_maxOutstanding() {
 	ctx := context.Background()
-	subscription := pubsublite.SubscriptionPath{Project: "project-id", Zone: "zone", SubscriptionID: "subscription-id"}
+	subscription := pubsublite.SubscriptionPath{
+		Project:        "project-id",
+		Zone:           "zone",
+		SubscriptionID: "subscription-id",
+	}
 	settings := ps.DefaultReceiveSettings
 	settings.MaxOutstandingMessages = 5
 	settings.MaxOutstandingBytes = 10e6
-	sub, err := ps.NewSubscriberClient(ctx, settings, subscription)
+	subscriber, err := ps.NewSubscriberClient(ctx, settings, subscription)
 	if err != nil {
 		// TODO: Handle error.
 	}
 	cctx, cancel := context.WithCancel(ctx)
-	err = sub.Receive(cctx, func(ctx context.Context, m *pubsub.Message) {
+	err = subscriber.Receive(cctx, func(ctx context.Context, m *pubsub.Message) {
 		// TODO: Handle message.
 		// NOTE: May be called concurrently; synchronize access to shared memory.
 		m.Ack()