Method Close

pubsub/pubsub.go:36–36

()

	Subscribe(ctx context.Context, topics ...string) error
	Unsubscribe(ctx context.Context, topics ...string) error
	Close() error
}