Merge pull request #874 from abicky/resolve-outside-of-example-error

Resolve RSpec::Mocks::OutsideOfExampleError

Author: dasch

Diff for: spec/async_producer_spec.rb

@@ -76,6 +76,8 @@ def instrument(name, payload = {})
       sleep 0.2 # wait for worker to call produce
 
       expect(sync_producer).to have_received(:produce)
+
+      async_producer.shutdown
     end
 
     it "retries until configured max_retries" do
@@ -89,6 +91,8 @@ def instrument(name, payload = {})
       metric = instrumenter.metrics_for("error.async_producer").first
       expect(metric.payload[:error]).to be_a(Kafka::BufferOverflow)
       expect(sync_producer).to have_received(:produce).exactly(3).times
+
+      async_producer.shutdown
     end
 
     it "requires `topic` to be a String" do