PubSub subscription example

main.go

package main

import (
	"context"
	"log"

	"cloud.google.com/go/pubsub"
)

func main() {
	ctx := context.Background()
	c, _ := pubsub.NewClient(ctx, "foo")
	s, _ := c.CreateSubscription(ctx, "bar", pubsub.SubscriptionConfig{
		Topic: c.Topic("foo"),
	})

	s.ReceiveSettings.MaxOutstandingMessages = 10

	s.Receive(ctx, func(ctx context.Context, m *pubsub.Message) {
		log.Println(string(m.Data))
	})
}