Minor change to examples for consistency

pubsublite/ps/example_test.go

@@ -76,12 +76,12 @@ 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)
+	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()
@@ -105,12 +105,12 @@ func ExampleSubscriberClient_Receive_maxOutstanding() {
 	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()