Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for TestWriteOnceCancel (0.38 sec)

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

    		t.Error("second Set() returned true")
    	}
    	goGetAndExpect(t, wr, gots, aval)
    	cancel()
    	time.Sleep(time.Second) // give it a chance to misbehave
    	goGetAndExpect(t, wr, gots, aval)
    }
    
    func TestWriteOnceCancel(t *testing.T) {
    	oldTime := time.Now()
    	cval := &oldTime
    	ctx, cancel := context.WithCancel(context.Background())
    	wr := NewWriteOnce(nil, ctx, cval)
    	gots := make(chan interface{})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 21 19:19:31 UTC 2023
    - 3K bytes
    - Viewed (0)
Back to top