Struct watcher

kv.go:961–971

Implementation for Watch

// Implementation for Watch
type watcher struct {
	mu            sync.Mutex
	updates       chan KeyValueEntry
	sub           *Subscription
	initDone      bool
	initPending   uint64
	received      uint64
	ctx           context.Context
	initDoneTimer *time.Timer
	errCh         chan error
}

// Context returns the context for the watcher if set.
func (w *watcher) Context() context.Context {