Method CreateSubscription

pubsub/gcppubsubv2/gcppubsub_test.go:99–102

(ctx context.Context, dt driver.Topic, testName string)

}

func (h *harness) CreateSubscription(ctx context.Context, dt driver.Topic, testName string) (ds driver.Subscription, cleanup func(), err error) {
	subName := fmt.Sprintf("%s-subscription-%d", sanitize(testName), atomic.AddUint32(&h.numSubs, 1))
	return createSubscription(ctx, h.client, dt, subName)
}

func createSubscription(ctx context.Context, client *raw.Client, dt driver.Topic, subName string) (ds driver.Subscription, cleanup func(), err error) {
	t := dt.(*topic)