Method update

cluster/topology/dynamic_test.go:194–204

()

}

func (w *testWatch) update() {
	w.Lock()
	if w.currentCalled < w.errAfter {
		w.data = getMockService(w.ctrl)
	} else {
		w.data = nil
	}
	w.currentCalled++
	w.Unlock()
	w.ch <- struct{}{}
}

func (w *testWatch) Close() {}