Close implements the io.Closer interface.
()
| 63 | |
| 64 | // Close implements the io.Closer interface. |
| 65 | func (r *reader) Close() error { |
| 66 | if r.dec != nil { |
| 67 | r.dec.Reset(devNull{}) // don't retain the underlying reader |
| 68 | decoderPool.Put(r.dec) |
| 69 | r.dec = nil |
| 70 | r.err = io.ErrClosedPipe |
| 71 | } |
| 72 | return nil |
| 73 | } |
| 74 | |
| 75 | // Read implements the io.Reader interface. |
| 76 | func (r *reader) Read(p []byte) (int, error) { |