Method Fire

internal/grpcsync/event.go:37–43

Fire causes e to complete. It is safe to call multiple times, and concurrently. It returns true iff this call to Fire caused the signaling channel returned by Done to close. If Fire returns false, it is possible the Done channel has not been closed yet.

()

// channel returned by Done to close. If Fire returns false, it is possible
// the Done channel has not been closed yet.
func (e *Event) Fire() bool {
	if e.fired.CompareAndSwap(false, true) {
		close(e.c)
		return true
	}
	return false
}

// Done returns a channel that will be closed when Fire is called.
func (e *Event) Done() <-chan struct{} {