()
| 43 | } |
| 44 | |
| 45 | func (r *resettableReader) Close() error { |
| 46 | closer, ok := r.reader.(io.Closer) |
| 47 | if ok { |
| 48 | return closer.Close() |
| 49 | } |
| 50 | return nil |
| 51 | } |
| 52 | |
| 53 | func newResettableReader(reader io.Reader, bufferLimit int64, onFinishCallback func([]byte)) *resettableReader { |
| 54 | return &resettableReader{ |
no outgoing calls