func()

in app/eventgen/generator/publishers/publishers.go [85:93]

• 8 lines of code
• 2 McCabe index (conditional complexity)

func (pbrs *Publishers) remove(pbr *publisher) {
	pbrs.Lock()
	defer pbrs.Unlock()

	pbrs.publishers = remove(pbrs.publishers, pbr)
	if len(pbrs.publishers) == 0 {
		pbrs.waitFinish.Broadcast() // All publisers are stopped, release all waiting routings
	}
}