in app/eventgen/generator/generator.go [82:92]
func (g *generator) release() {
g.topic.Stop()
if err := g.client.Close(); err != nil {
log.Printf("fail to close Cloud Pub/Sub client, err: %v", err)
}
mux.Lock()
defer mux.Unlock()
if running == g {
running = nil
}
}