Sha256: 5d05bf770f284d1e3c30b231d976d9c8399dae5033515f0ff97eb9b7bc440bce
Contents?: true
Size: 742 Bytes
Versions: 93
Compression:
Stored size: 742 Bytes
Contents
require 'rspec/wait'
RSpec.shared_examples "an interruptible input plugin" do
describe "#stop" do
let(:queue) { SizedQueue.new(20) }
subject { described_class.new(config) }
before(:each) { subject.register }
it "returns from run" do
consumer_thread = Thread.new(queue) { |queue| loop { queue.pop } }
plugin_thread = Thread.new(subject, queue) { |subject, queue| subject.run(queue) }
# the run method is a long lived one, so it should still be running after "a bit"
sleep 0.5
expect(plugin_thread).to be_alive
# now let's actually stop the plugin
subject.do_stop
# why 3? 2 is not enough, 4 is too much..
wait(3).for { plugin_thread }.to_not be_alive
end
end
end
Version data entries
93 entries across 86 versions & 18 rubygems