(ctx context.Context, client *raw.Client, subName string)
| 126 | } |
| 127 | |
| 128 | func deleteSubscription(ctx context.Context, client *raw.Client, subName string) { |
| 129 | _ = client.SubscriptionAdminClient.DeleteSubscription(ctx, &pubsubpb.DeleteSubscriptionRequest{ |
| 130 | Subscription: subscriptionPath(subName)}, |
| 131 | ) |
| 132 | } |
| 133 | |
| 134 | func (h *harness) MakeNonexistentSubscription(ctx context.Context) (driver.Subscription, func(), error) { |
| 135 | return openSubscription(h.client.Subscriber("nonexistent-subscription"), nil), func() {}, nil |
no test coverage detected