close shuts down the muter, waking any goroutines blocked in waitUntilMuted.
()
| 267 | |
| 268 | // close shuts down the muter, waking any goroutines blocked in waitUntilMuted. |
| 269 | func (m *partitionMuter) close() { |
| 270 | m.mu.Lock() |
| 271 | defer m.mu.Unlock() |
| 272 | |
| 273 | if m.closed { |
| 274 | return |
| 275 | } |
| 276 | m.closed = true |
| 277 | close(m.unmuteSignal) |
| 278 | m.cond.Broadcast() |
| 279 | } |
| 280 | |
| 281 | // NewAsyncProducer creates a new AsyncProducer using the given broker addresses and configuration. |
| 282 | func NewAsyncProducer(addrs []string, conf *Config) (AsyncProducer, error) { |
no outgoing calls