in app/eventgen/generator/publishers/publishers.go [115:121]
func (pbrs *Publishers) WaitFinish() { pbrs.Lock() defer pbrs.Unlock() for len(pbrs.publishers) > 0 { pbrs.waitFinish.Wait() // Waiting until no running publishers } }