Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for Test_BoundedFrequencyRunnerBurst (0.3 sec)

  1. pkg/util/async/bounded_frequency_runner_test.go

    	stop <- struct{}{}
    	// a message is sent to time.updated in func Stop() at the end of the child goroutine
    	// to terminate the child, a receive on time.updated is needed here
    	<-timer.updated
    }
    
    func Test_BoundedFrequencyRunnerBurst(t *testing.T) {
    	obj := &receiver{}
    	timer := newFakeTimer()
    	runner := construct("test-runner", obj.F, minInterval, maxInterval, 2, timer)
    	stop := make(chan struct{})
    
    	var upd timerUpdate
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 15 09:36:26 UTC 2022
    - 12.5K bytes
    - Viewed (0)
Back to top