func()

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)
}