clientv3/concurrency/election.go
func (e *Election) Observe(ctx context.Context) <-chan v3.GetResponse {
	retc := make(chan v3.GetResponse)
	go e.observe(ctx, retc)
	return retc
}
func (e *Election) Observe(ctx context.Context) <-chan v3.GetResponse {
	retc := make(chan v3.GetResponse)
	go e.observe(ctx, retc)
	return retc
}
func ( e * Election ) Observe ( ctx context . Context ) <- chan v3 . GetResponse { retc := make ( chan v3 . GetResponse ) go e . observe ( ctx , retc ) return retc }
// Observe returns a channel that reliably observes ordered leader proposals
// as GetResponse values on every current elected leader key. It will not
// necessarily fetch all historical leader updates, but will always post the
// most recent leader value.
//
// The channel closes when the context is canceled or the underlying watcher
// is otherwise disrupted.
Observe returns a channel that reliably observes ordered leader proposals as GetResponse values on every current elected leader key . It will not necessarily fetch all historical leader updates but will always post the most recent leader value . The channel closes when the context is canceled or the underlying watcher is otherwise disrupted .