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)