kubernetes/staging/src/k8s.io/client-go/tools/cache/testing/fake_controller_source_test.go

// ensure the watch delivers the requested and only the requested items.
func consume(t *testing.T, w watch.Interface, rvs []string, done *sync.WaitGroup) { … }

func TestRCNumber(t *testing.T) { … }

// TestResetWatch validates that the FakeController correctly mocks a watch
// falling behind and ResourceVersions aging out.
func TestResetWatch(t *testing.T) { … }