poll executes f every interval until ctx is done or cancelled.
(ctx context.Context, interval time.Duration, f func())
| 337 | |
| 338 | // poll executes f every interval until ctx is done or cancelled. |
| 339 | func poll(ctx context.Context, interval time.Duration, f func()) { |
| 340 | ticker := time.NewTicker(interval) |
| 341 | defer ticker.Stop() |
| 342 | |
| 343 | for { |
| 344 | select { |
| 345 | case <-ctx.Done(): |
| 346 | return |
| 347 | case <-ticker.C: |
| 348 | f() |
| 349 | } |
| 350 | } |
| 351 | } |
| 352 | |
| 353 | var _ Overrides = (*mockOverrides)(nil) |
| 354 |
no test coverage detected