View definition

(*PartitionConsumer).ExpectMessagesDrainedOnClose

Defined in github.com/Shopify/sarama/mocks/consumer.go

Description

ExpectMessagesDrainedOnClose sets an expectation on the partition consumer that the messages channel will be fully drained when Close is called. If this expectation is not met, an error is reported to the error reporter.

ExpectMessagesDrainedOnClose is referenced in 1 repository

github.com/Shopify/sarama