spec/rflow/components/clock_spec.rb in rflow-1.0.0a2 vs spec/rflow/components/clock_spec.rb in rflow-1.0.0a3

- old
+ new

@@ -5,66 +5,61 @@ describe Clock do before(:each) do ActiveRecord::Base.establish_connection adapter: "sqlite3", database: ":memory:" Configuration.migrate_database end - let(:config) do - RFlow::Configuration::Component.new.tap do |c| - c.output_ports << RFlow::Configuration::OutputPort.new(name: 'tick_port') - end - end let(:message_connection) { RFlow::MessageCollectingConnection.new } def clock(args = {}) - Clock.new(config).tap do |c| + Clock.new.tap do |c| c.configure! args c.tick_port.connect! c.tick_port.add_connection nil, message_connection end end def messages; message_connection.messages; end it 'defaults configuration nicely' do clock.tap do |c| - c.clock_name.should == 'Clock' - c.tick_interval.should == 1 + expect(c.clock_name).to eq('Clock') + expect(c.tick_interval).to eq(1) end end it 'supports name overrides' do clock('name' => 'testname').tap do |c| - c.clock_name.should == 'testname' + expect(c.clock_name).to eq('testname') end end it 'supports interval overrides for floats' do clock('tick_interval' => 1.5).tap do |c| - c.tick_interval.should == 1.5 + expect(c.tick_interval).to eq(1.5) end end it 'supports interval overrides for strings' do clock('tick_interval' => '1.5').tap do |c| - c.tick_interval.should == 1.5 + expect(c.tick_interval).to eq(1.5) end end it 'should register a timer' do - EventMachine::PeriodicTimer.should_receive(:new).with(1) + expect(EventMachine::PeriodicTimer).to receive(:new).with(1) clock.run! end it 'should generate a tick message when asked' do clock.tap do |c| now = Integer(Time.now.to_f * 1000) - messages.should be_empty + expect(messages).to be_empty c.tick - messages.should have(1).message + expect(messages).to have(1).message messages.first.tap do |m| - m.data_type_name.should == 'RFlow::Message::Clock::Tick' - m.data.name.should == 'Clock' - m.data.timestamp.should >= now + expect(m.data_type_name).to eq('RFlow::Message::Clock::Tick') + expect(m.data.name).to eq('Clock') + expect(m.data.timestamp).to be >= now end end end end end