Method C

internal/carrier/client.go:259–263

C returns the current channel to select on. Must be captured before entering select so a concurrent Broadcast() cannot be missed.

()

// C returns the current channel to select on. Must be captured before
// entering select so a concurrent Broadcast() cannot be missed.
func (w *waker) C() <-chan struct{} {
	w.mu.Lock()
	defer w.mu.Unlock()
	return w.ch
}

// Broadcast unblocks all goroutines currently waiting on C().
func (w *waker) Broadcast() {