Method monitorKeyNotifications

kv/memberlist/memberlist_client.go:1183–1196

monitorKeyNotifications sends accumulated notifications to all watchers of respective keys when the given channel ticks.

(ctx context.Context, tickChan <-chan time.Time)

// monitorKeyNotifications sends accumulated notifications to all watchers of
// respective keys when the given channel ticks.
func (m *KV) monitorKeyNotifications(ctx context.Context, tickChan <-chan time.Time) {
	if m.cfg.NotifyInterval <= 0 {
		panic("sendNotifications called with NotifyInterval <= 0")
	}

	for {
		select {
		case <-tickChan:
			m.sendKeyNotifications()
		case <-ctx.Done():
			return
		}
	}
}

// sendKeyNotifications sends accumulated notifications to watchers of respective keys.
func (m *KV) sendKeyNotifications() {