Sha256: 3acfb5dd06e1527b8e36370980910816fc16d895ea354f9212096e6eaac5c1b8
Contents?: true
Size: 1.57 KB
Versions: 6
Compression:
Stored size: 1.57 KB
Contents
require 'spec_helper'
shared_examples "a Protobuf Connector" do
subject{ described_class.new({}) }
context "API" do
# Check the API
specify{ subject.respond_to?(:send_request, true).should be_true }
specify{ subject.respond_to?(:post_init, true).should be_true }
specify{ subject.respond_to?(:close_connection, true).should be_true }
specify{ subject.respond_to?(:error?, true).should be_true }
end
end
describe Protobuf::Rpc::Connectors::Socket do
subject{ described_class.new({}) }
it_behaves_like "a Protobuf Connector"
specify{ described_class.include?(Protobuf::Rpc::Connectors::Common).should be_true }
context "#read_response" do
let(:data){ "New data" }
it "fills the buffer with data from the socket" do
socket = StringIO.new("#{data.bytesize}-#{data}")
subject.instance_variable_set(:@buffer, Protobuf::Rpc::Buffer.new(:read))
subject.instance_variable_set(:@socket, socket)
subject.should_receive(:parse_response).and_return(true)
subject.__send__(:read_response)
subject.instance_variable_get(:@buffer).flushed?.should be_true
subject.instance_variable_get(:@buffer).data.should eq(data)
end
end
context "#check_async" do
it "raises an error when trying to execute asynchronously" do
conn = described_class.new(:async => true)
expect{ conn.__send__(:check_async) }.to raise_error
end
it "allows execution when synchronous" do
conn = described_class.new(:async => false)
expect{ conn.__send__(:check_async) }.to_not raise_error
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems