Function newTopic

pubsub/pubsub.go:347–356

newTopic makes a pubsub.Topic from a driver.Topic. opts may be nil to accept defaults.

(d driver.Topic, opts *batcher.Options)

//
// opts may be nil to accept defaults.
func newTopic(d driver.Topic, opts *batcher.Options) *Topic {
	ctx, cancel := context.WithCancel(context.Background())
	t := &Topic{
		driver: d,
		tracer: gcdkotel.NewTracer(pkgName, gcdkotel.ProviderName(d)),
		cancel: cancel,
	}
	t.batcher = newSendBatcher(ctx, t, d, opts)
	return t
}

const pkgName = "gocloud.dev/pubsub"