spec/lib/flapjack/coordinator_spec.rb in flapjack-0.9.5 vs spec/lib/flapjack/coordinator_spec.rb in flapjack-0.9.6

- old
+ new

@@ -31,11 +31,11 @@ expect(Flapjack::Pikelet).to receive(:create).with('processor', :config => cfg['processor'], :redis_config => {}, :boot_time => time). and_return(processor) expect(EM).to receive(:stop) - expect(EM::Synchrony).to receive(:sleep).and_return { + expect(EM::Synchrony).to receive(:sleep) { fc.instance_variable_set('@received_signals', ['INT']) } expect(Syslog).to receive(:opened?).and_return(true) expect(Syslog).to receive(:close) @@ -100,11 +100,11 @@ expect(Flapjack::Pikelet).to receive(:create).with('notifier', :config => cfg['executive'], :redis_config => {}, :boot_time => time). and_return(notifier) expect(EM).to receive(:stop) - expect(EM::Synchrony).to receive(:sleep).and_return { + expect(EM::Synchrony).to receive(:sleep) { fc.instance_variable_set('@received_signals', ['INT']) } expect(Syslog).to receive(:opened?).and_return(true) expect(Syslog).to receive(:close) @@ -134,10 +134,10 @@ :config => cfg['executive'].merge(cfg['processor']), :redis_config => {}, :boot_time => time). and_return(processor) expect(EM).to receive(:stop) - expect(EM::Synchrony).to receive(:sleep).and_return { + expect(EM::Synchrony).to receive(:sleep) { fc.instance_variable_set('@received_signals', ['INT']) } expect(Syslog).to receive(:opened?).and_return(true) expect(Syslog).to receive(:close)