Sha256: 3f0381e367bf02276b05ff78d8a3cb906dcb09ba6113d8a9e26b09dfcbc0e7a9
Contents?: true
Size: 1.67 KB
Versions: 2
Compression:
Stored size: 1.67 KB
Contents
require 'spec_helper' require 'spec/proto/test_service_impl' require 'protobuf/rpc/servers/socket_runner' describe Protobuf::Rpc::SocketServer do before(:all) do server = OpenStruct.new(:server => "127.0.0.1", :port => 9399, :backlog => 100, :threshold => 100) @server_thread = Thread.new(server) { |s| Protobuf::Rpc::SocketRunner.run(s) } Thread.pass until Protobuf::Rpc::SocketServer.running? end after(:all) do Protobuf::Rpc::SocketRunner.stop Thread.kill(@server_thread) end it "Runner provides a stop method" do runner_class = described_class.to_s.gsub(/Server/, "Runner") runner_class = Protobuf::Util.constantize(runner_class) runner_class.respond_to?(:stop).should be_true end it "provides a stop method" do described_class.respond_to?(:stop).should be_true end it "provides a Runner class" do runner_class = described_class.to_s.gsub(/Server/, "Runner") expect { Protobuf::Util.constantize(runner_class) }.to_not raise_error end it "signals the Server is running" do described_class.running?.should be_true end context "Eventmachine client" do it "calls the service in the client request" do with_constants "Protobuf::ConnectorType" => "Evented" do client = Spec::Proto::TestService.client(:async => false, :port => 9399, :host => "127.0.0.1") client.find(:name => "Test Name", :active => true) do |c| c.on_success do |succ| succ.name.should eq("Test Name") succ.status.should eq(Spec::Proto::StatusType::ENABLED) end c.on_failure do |err| raise err.inspect end end end end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
protobuf-1.1.0.beta1 | spec/unit/rpc/servers/socket_server_spec.rb |
protobuf-1.1.0.beta0 | spec/unit/rpc/servers/socket_server_spec.rb |