kubernetes/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/promise/counting_test.go

func TestMain(m *testing.M) { … }

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

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

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

func goGetExpectNotYet(t *testing.T, clk *testeventclock.Fake, grc counter.GoRoutineCounter, wr promise.WriteOnce, gots chan interface{ … }

func goGetAndExpect(t *testing.T, clk *testeventclock.Fake, grc counter.GoRoutineCounter, wr promise.WriteOnce, gots chan interface{ … }

func expectGotValue(t *testing.T, gots <-chan interface{ … }