(ctx context.Context, err error)
| 1558 | } |
| 1559 | |
| 1560 | func (r *reader) sendError(ctx context.Context, err error) error { |
| 1561 | select { |
| 1562 | case r.msgs <- readerMessage{version: r.version, error: err}: |
| 1563 | return nil |
| 1564 | case <-ctx.Done(): |
| 1565 | return ctx.Err() |
| 1566 | } |
| 1567 | } |
| 1568 | |
| 1569 | func (r *reader) withLogger(do func(Logger)) { |
| 1570 | if r.logger != nil { |