func()

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
	}
}