spec/rflow/component/port_spec.rb in rflow-1.0.1 vs spec/rflow/component/port_spec.rb in rflow-1.1.0
- old
+ new
@@ -1,51 +1,51 @@
require 'spec_helper'
class RFlow
class Component
- context "Input and output ports" do
+ context 'Input and output ports' do
let(:connection) { RFlow::Connection.new(RFlow::Configuration::NullConnectionConfiguration.new) }
let(:message) { RFlow::Message.new('RFlow::Message::Data::Raw') }
describe Port do
- it "should not be connected" do
+ it 'should not be connected' do
expect(described_class.new(nil)).not_to be_connected
end
end
describe HashPort do
- it "should not be connected" do
+ it 'should not be connected' do
expect(described_class.new(nil)).not_to be_connected
end
end
[InputPort, OutputPort].each do |c|
describe c do
- context "#add_connection" do
- it "should add the connection" do
+ context '#add_connection' do
+ it 'should add the connection' do
described_class.new(nil).tap do |port|
port.add_connection(nil, connection)
- expect(port[nil]).to include connection
+ expect(port[nil].connections).to include connection
end
end
end
- context "#remove_connection" do
- it "should remove the connection" do
+ context '#remove_connection' do
+ it 'should remove the connection' do
described_class.new(nil).tap do |port|
port.add_connection(nil, connection)
port.remove_connection(nil, connection)
- expect(port[nil]).not_to include connection
+ expect(port[nil].connections).not_to include connection
end
end
end
end
end
describe InputPort do
- context "#connect!" do
- it "should be connected" do
+ context '#connect!' do
+ it 'should be connected' do
expect(connection).to receive(:connect_input!)
described_class.new(nil).tap do |port|
port.add_connection(nil, connection)
expect(port).not_to be_connected
@@ -55,12 +55,12 @@
end
end
end
describe OutputPort do
- context "#connect!" do
- it "should be connected" do
+ context '#connect!' do
+ it 'should be connected' do
expect(connection).to receive(:connect_output!)
described_class.new(nil).tap do |port|
port.add_connection(nil, connection)
expect(port).not_to be_connected
@@ -68,12 +68,12 @@
expect(port).to be_connected
end
end
end
- context "#add_connection" do
- it "should deliver messages to the new connection" do
+ context '#add_connection' do
+ it 'should deliver messages to the new connection' do
described_class.new(nil).tap do |port|
port.connect!
port.all_connections # trigger caching
expect(connection).to receive(:connect_output!)
@@ -83,11 +83,11 @@
port.send_message(message)
end
end
end
- context "#remove_connection" do
- it "should not deliver messages to the old connection" do
+ context '#remove_connection' do
+ it 'should not deliver messages to the old connection' do
described_class.new(nil).tap do |port|
allow(connection).to receive(:connect_output!)
port.add_connection(nil, connection)
port.connect!
port.all_connections # trigger caching