Method Wait

pkg/concurrency/executed.go:68–74

Wait waits for execution

()

// Wait waits for execution
func (i *Executed) Wait() {
	i.cond.L.Lock()
	defer i.cond.L.Unlock()
	if !i.done {
		i.cond.Wait()
	}
}

// Broadcast broadcasts execution to waiting goroutines
func (i *Executed) Broadcast() {