| 513 | if err != nil { |
| 514 | c.sem.Release(maxMsg) |
| 515 | if c.cfg.FiniteConsumption && errors.Is(err, sql.ErrNoRows) { |
| 516 | return nil, io.EOF |
| 517 | } |
| 518 | if !errors.Is(err, sql.ErrNoRows) { |
| 519 | return nil, errors.WithStack(err) |
| 520 | } |
| 521 | select { |
| 522 | case <-ctx.Done(): |
| 523 | return nil, fatalError{Err: ctx.Err()} |
| 524 | case <-time.After(c.cfg.PollingInterval): |
nothing calls this directly
no outgoing calls
no test coverage detected