Function TestTopicCloseIsCalled

pubsub/pub_test.go:83–91

(t *testing.T)

}

func TestTopicCloseIsCalled(t *testing.T) {
	ctx := context.Background()
	dt := &funcTopic{}
	topic := pubsub.NewTopic(dt, nil)
	topic.Shutdown(ctx)
	if !dt.closed {
		t.Error("want Topic.Close to have been called")
	}
}