(ir io.Reader)
| 116 | } |
| 117 | |
| 118 | func (r *reader) Reset(ir io.Reader) error { |
| 119 | _, err := r.cbuff.ReadFrom(ir) |
| 120 | |
| 121 | if err != nil { |
| 122 | return err |
| 123 | } |
| 124 | |
| 125 | r.dst, err = snappy.Decode(r.dst, r.cbuff.Bytes()) |
| 126 | |
| 127 | if err != nil { |
| 128 | return err |
| 129 | } |
| 130 | |
| 131 | r.dbuff = bytes.NewBuffer(r.dst) |
| 132 | return nil |
| 133 | } |
| 134 | |
| 135 | func (r *reader) Read(p []byte) (n int, err error) { |
| 136 | n, err = r.dbuff.Read(p) |