in app/eventgen/generator/generator.go [72:79]
func (g *generator) Stop() {
if g.publishers != nil {
g.publishers.Stop() // Resources will be released after all publishers have finished
g.cancel() // Force stop the generator
} else {
g.release()
}
}