(ctx context.Context, client *raw.Client, topicName string)
| 87 | } |
| 88 | |
| 89 | func deleteTopic(ctx context.Context, client *raw.Client, topicName string) { |
| 90 | _ = client.TopicAdminClient.DeleteTopic(ctx, &pubsubpb.DeleteTopicRequest{ |
| 91 | Topic: topicPath(topicName), |
| 92 | }) |
| 93 | } |
| 94 | |
| 95 | func (h *harness) MakeNonexistentTopic(ctx context.Context) (driver.Topic, error) { |
| 96 | return openTopic(h.client.Publisher("nonexistent-topic")), nil |
no test coverage detected