MCPcopy
hub / github.com/IBM/sarama / AsyncClose

Method AsyncClose

async_producer.go:581–583  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

579}
580
581func (p *asyncProducer) AsyncClose() {
582 go withRecover(p.shutdown)
583}
584
585// singleton
586// dispatches messages by topic

Callers 1

CloseMethod · 0.95

Calls 1

withRecoverFunction · 0.85

Tested by

no test coverage detected