(wb *writeBuffer)
| 282 | } |
| 283 | |
| 284 | func (t offsetCommitResponseV2) writeTo(wb *writeBuffer) { |
| 285 | wb.writeArray(len(t.Responses), func(i int) { t.Responses[i].writeTo(wb) }) |
| 286 | } |
| 287 | |
| 288 | func (t *offsetCommitResponseV2) readFrom(r *bufio.Reader, size int) (remain int, err error) { |
| 289 | fn := func(r *bufio.Reader, withSize int) (fnRemain int, fnErr error) { |