()
| 1360 | } |
| 1361 | |
| 1362 | func (bc *brokerConsumer) stopConsuming() { |
| 1363 | bc.stopOnce.Do(func() { |
| 1364 | close(bc.stop) |
| 1365 | }) |
| 1366 | } |
| 1367 | |
| 1368 | func (bc *brokerConsumer) releaseSubscription(child *partitionConsumer) { |
| 1369 | if subscription, ok := bc.subscriptions[child]; ok { |
no outgoing calls
no test coverage detected