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

Method Successes

async_producer.go:59–59  ·  view source on GitHub ↗

Successes is the success output channel back to the user when Return.Successes is enabled. If Return.Successes is true, you MUST read from this channel or the Producer will deadlock. It is suggested that you send and read messages together in a single select statement.

()

Source from the content-addressed store, hash-verified

57 // Producer will deadlock. It is suggested that you send and read messages
58 // together in a single select statement.
59 Successes() <-chan *ProducerMessage
60
61 // Errors is the error output channel back to the user. You MUST read from this
62 // channel or the Producer will deadlock when the channel is full. Alternatively,

Implementers 2

asyncProducerasync_producer.go
AsyncProducermocks/async_producer.go

Calls

no outgoing calls