(n int)
| 625 | } |
| 626 | |
| 627 | func (d *Decoder) readN(n int) ([]byte, error) { |
| 628 | var err error |
| 629 | if d.flags&disableAllocLimitFlag != 0 { |
| 630 | d.buf, err = readN(d.r, d.buf, n) |
| 631 | } else { |
| 632 | d.buf, err = readNGrow(d.r, d.buf, n) |
| 633 | } |
| 634 | if err != nil { |
| 635 | return nil, err |
| 636 | } |
| 637 | if d.rec != nil { |
| 638 | // TODO: read directly into d.rec? |
| 639 | d.rec = append(d.rec, d.buf...) |
| 640 | } |
| 641 | return d.buf, nil |
| 642 | } |
| 643 | |
| 644 | func readN(r io.Reader, b []byte, n int) ([]byte, error) { |
| 645 | if b == nil { |
no test coverage detected