()
| 271 | } |
| 272 | |
| 273 | func (m *MockConn) Close() error { |
| 274 | select { |
| 275 | case <-m.done: |
| 276 | default: |
| 277 | close(m.done) |
| 278 | } |
| 279 | return nil |
| 280 | } |
| 281 | |
| 282 | func (m *MockConn) ReadPartitions(topics ...string) (partitions []Partition, err error) { |
| 283 | return m.partitions, err |