(ctx context.Context, err error)
| 834 | } |
| 835 | |
| 836 | func (w *worker) handleError(ctx context.Context, err error) { |
| 837 | if w.bi.config.OnError != nil { |
| 838 | w.bi.config.OnError(ctx, err) |
| 839 | } |
| 840 | w.notifyItemsOnError(err) |
| 841 | } |
| 842 | |
| 843 | type defaultJSONDecoder struct{} |
| 844 |
no test coverage detected