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

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

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

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

func goGetExpectNotYet(t *testing.T, wr WriteOnce, gots chan interface{ … }

func goGetAndExpect(t *testing.T, wr WriteOnce, gots chan interface{ … }

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