Method Wait

asyncbuffer/cond.go:47–68

Wait waits for a Tick() to occur after the given cursor value. Returns the new cursor value when awakened. If the cursor has already advanced beyond the given value, returns immediately with the current cursor.

(cursor uint64)

// Returns the new cursor value when awakened.
// If the cursor has already advanced beyond the given value, returns immediately with the current cursor.
func (t *Cond) Wait(cursor uint64) uint64 {
	t.mu.RLock()
	ch := t.ch
	current := t.cursor.Load()
	t.mu.RUnlock()

	// If cursor already advanced, return immediately
	if current != cursor || ch == nil {
		return current
	}

	// Wait for the channel to close (Tick happened)
	// If Tick happens after t.mu.RUnlock() and here, we will just wait on a
	// closed channel and return updated cursor value.
	<-ch

	// NOTE: Another Tick() could happen here before we read cursor.
	// This is acceptable - we return the current cursor value, which may be
	// newer than the Tick() that woke us. The caller will use this cursor
	// for the next wait cycle and re-check their condition.
	return t.cursor.Load()
}

// Close closes the ticker channel and prevents further ticks.
func (t *Cond) Close() {