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

Method ExpectInputAndSucceed

mocks/async_producer.go:267–271  ·  view source on GitHub ↗

ExpectInputAndSucceed sets an expectation on the mock producer that a message will be provided on the input channel. The mock producer will handle the message as if it is produced successfully, i.e. it will make it available on the Successes channel if the Producer.Return.Successes setting is set to

()

Source from the content-addressed store, hash-verified

265// i.e. it will make it available on the Successes channel if the Producer.Return.Successes setting
266// is set to true.
267func (mp *AsyncProducer) ExpectInputAndSucceed() *AsyncProducer {
268 mp.ExpectInputWithMessageCheckerFunctionAndSucceed(nil)
269
270 return mp
271}
272
273// ExpectInputAndFail sets an expectation on the mock producer that a message will be provided
274// on the input channel. The mock producer will handle the message as if it failed to produce

Implementers 2

asyncProducerasync_producer.go
AsyncProducermocks/async_producer.go