Method Tick

asyncbuffer/cond.go:27–36

Tick signals that an event has occurred by closing the channel and incrementing cursor.

()

// Tick signals that an event has occurred by closing the channel and incrementing cursor.
func (t *Cond) Tick() {
	t.mu.Lock()
	defer t.mu.Unlock()

	if t.ch != nil {
		t.cursor.Add(1)     // Increment FIRST so waiters see new cursor when they wake
		close(t.ch)         // Then close channel to wake waiters
		t.ch = make(condCh) // Create new channel for next Tick
	}
}

// Cursor returns the current cursor value.
// Capture this before checking your condition, then pass it to Wait().