(wb *writeBuffer)
| 344 | } |
| 345 | |
| 346 | func (t joinGroupResponse) writeTo(wb *writeBuffer) { |
| 347 | if t.v >= v2 { |
| 348 | wb.writeInt32(t.ThrottleTime) |
| 349 | } |
| 350 | wb.writeInt16(t.ErrorCode) |
| 351 | wb.writeInt32(t.GenerationID) |
| 352 | wb.writeString(t.GroupProtocol) |
| 353 | wb.writeString(t.LeaderID) |
| 354 | wb.writeString(t.MemberID) |
| 355 | wb.writeArray(len(t.Members), func(i int) { t.Members[i].writeTo(wb) }) |
| 356 | } |
| 357 | |
| 358 | func (t *joinGroupResponse) readFrom(r *bufio.Reader, size int) (remain int, err error) { |
| 359 | remain = size |