Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for TestJitterUntil (0.18 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/wait/wait_test.go

    		}
    		close(ch)
    	}, 30*time.Second, ch)
    	if now.Add(25 * time.Second).Before(time.Now()) {
    		t.Errorf("Until did not return immediately when the stop chan was closed inside the func")
    	}
    }
    
    func TestJitterUntil(t *testing.T) {
    	ch := make(chan struct{})
    	// if a channel is closed JitterUntil never calls function f
    	// and returns immediately
    	close(ch)
    	JitterUntil(func() {
    		t.Fatal("should not have been invoked")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 41.1K bytes
    - Viewed (0)
Back to top