(dst []byte)
| 198 | } |
| 199 | |
| 200 | func (d *decoder) Read(dst []byte) (int, error) { |
| 201 | if len(d.out) == 0 { |
| 202 | if d.nextProof == nil { |
| 203 | // Already processed all records. |
| 204 | return 0, io.EOF |
| 205 | } |
| 206 | if err := d.readNextRecord(); err != nil { |
| 207 | return 0, err |
| 208 | } |
| 209 | } |
| 210 | n := copy(dst, d.out) |
| 211 | d.out = d.out[n:] |
| 212 | return n, nil |
| 213 | } |
| 214 | |
| 215 | func (d *decoder) readNextRecord() error { |
| 216 | readBytes, err := io.ReadFull(d.r, d.recordBuf) |
no test coverage detected