Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for generateWaitFunc (0.39 sec)

  1. pkg/volume/util/nestedpendingoperations/nestedpendingoperations_test.go

    	opZContinueCh := make(chan interface{})
    	op1ContinueCh := make(chan interface{})
    	op2ContinueCh := make(chan interface{})
    	operationZ := generateWaitFunc(opZContinueCh)
    	operation1 := generateWaitFunc(op1ContinueCh)
    	operation2 := generateWaitWithErrorFunc(op2ContinueCh)
    	operation3 := noopFunc
    	operation4 := noopFunc
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 26 01:29:17 UTC 2022
    - 36.1K bytes
    - Viewed (0)
  2. pkg/util/goroutinemap/goroutinemap_test.go

    	// Arrange
    	grm := NewGoRoutineMap(false /* exponentialBackOffOnError */)
    	operationName := "operation-name"
    	operation1DoneCh := make(chan interface{}, 0 /* bufferSize */)
    	operation1 := generateWaitFunc(operation1DoneCh)
    	err1 := grm.Run(operationName, operation1)
    	if err1 != nil {
    		t.Fatalf("NewGoRoutine failed. Expected: <no error> Actual: <%v>", err1)
    	}
    	operation2 := generateNoopFunc()
    
    	// Act
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 11 14:09:48 UTC 2017
    - 14.9K bytes
    - Viewed (0)
Back to top