(q DelayingInterface, depth int)
| 235 | } |
| 236 | |
| 237 | func waitForAdded(q DelayingInterface, depth int) error { |
| 238 | return wait.Poll(1*time.Millisecond, 10*time.Second, func() (done bool, err error) { |
| 239 | if q.Len() == depth { |
| 240 | return true, nil |
| 241 | } |
| 242 | |
| 243 | return false, nil |
| 244 | }) |
| 245 | } |
| 246 | |
| 247 | func waitForWaitingQueueToFill(q DelayingInterface) error { |
| 248 | return wait.Poll(1*time.Millisecond, 10*time.Second, func() (done bool, err error) { |
no test coverage detected