(need int)
| 85 | } |
| 86 | |
| 87 | func (c *compIO) readNext(need int) ([]byte, error) { |
| 88 | for c.buff.Len() < need { |
| 89 | if err := c.readCompressedPacket(); err != nil { |
| 90 | return nil, err |
| 91 | } |
| 92 | } |
| 93 | data := c.buff.Next(need) |
| 94 | return data[:need:need], nil // prevent caller writes into c.buff |
| 95 | } |
| 96 | |
| 97 | func (c *compIO) readCompressedPacket() error { |
| 98 | header, err := c.mc.readNext(7) |
no test coverage detected