(ctx context.Context)
| 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 |
| 136 | } |
| 137 | |
| 138 | func (h *harness) Close() { |
| 139 | h.client.Close() |
nothing calls this directly
no test coverage detected