(ctx context.Context, delay time.Duration)
| 257 | } |
| 258 | |
| 259 | func waitForRetry(ctx context.Context, delay time.Duration) error { |
| 260 | timer := time.NewTimer(delay) |
| 261 | defer timer.Stop() |
| 262 | |
| 263 | select { |
| 264 | case <-ctx.Done(): |
| 265 | return ctx.Err() |
| 266 | case <-timer.C: |
| 267 | return nil |
| 268 | } |
| 269 | } |
no test coverage detected