Fixed bug where producer.stop() did not block until the producer actually exited. This bug caused the producer to continue producing/flushing while the consumer consumed.
Fixed bug where producer.stop() did not block until the producer actually exited. This bug caused the producer to continue producing/flushing while the consumer consumed.

edenhill/muckrake,edenhill/muckrake