in readers/apiserver/watchlist/watchlist.go [123:135]
func (r *Reader) Close(ctx context.Context) error { r.mu.Lock() defer r.mu.Unlock() close(r.closeCh) defer func() { if r.ch != nil { close(r.ch) } }() return r.r.Close(ctx) }