Function openTopic

pubsub/gcppubsubv2/gcppubsub.go:357–359

openTopic returns the driver for OpenTopic. This function exists so the test harness can get the driver interface implementation if it needs to.

(publisher *raw.Publisher)

// openTopic returns the driver for OpenTopic. This function exists so the test
// harness can get the driver interface implementation if it needs to.
func openTopic(publisher *raw.Publisher) driver.Topic {
	return &topic{publisher}
}

// SendBatch implements driver.Topic.SendBatch.
func (t *topic) SendBatch(ctx context.Context, dms []*driver.Message) error {