()
| 279 | } |
| 280 | |
| 281 | func (t createTopicsRequest) size() int32 { |
| 282 | sz := sizeofArray(len(t.Topics), func(i int) int32 { return t.Topics[i].size() }) + |
| 283 | sizeofInt32(t.Timeout) |
| 284 | if t.v >= v1 { |
| 285 | sz += 1 |
| 286 | } |
| 287 | return sz |
| 288 | } |
| 289 | |
| 290 | func (t createTopicsRequest) writeTo(wb *writeBuffer) { |
| 291 | wb.writeArray(len(t.Topics), func(i int) { t.Topics[i].writeTo(wb) }) |
nothing calls this directly
no test coverage detected