Sha256: bd30af4a320e475c5507cc70c7278ea911ad1a0ca30fc6b33d5802e0619c4e50

Contents?: true

Size: 629 Bytes

Versions: 81

Compression:

Stored size: 629 Bytes

Contents

module Protobuf
  module Rpc
    class ZmqRunner

      def self.stop
        Protobuf::Rpc::Zmq::Server.stop
      end

      def self.run(server)
        server_config = case
                        when server.is_a?(OpenStruct) then
                          server.marshal_dump
                        when server.respond_to?(:to_hash) then
                          server.to_hash
                        else
                          raise "Cannot parser Zmq Server - server options"
                        end

				yield if block_given?
        Protobuf::Rpc::Zmq::Server.run(server_config)
      end
    end

  end
end

Version data entries

81 entries across 81 versions & 1 rubygems

Version Path
protobuf-2.7.2-java lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.7.2 lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.7.1-java lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.7.1 lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.7.0-java lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.7.0 lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.7.0.rc1-java lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.7.0.rc1 lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.6.6-java lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.6.6 lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.6.5-java lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.6.5 lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.6.4-java lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.6.4 lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.6.3-java lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.6.3 lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.6.2-java lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.6.2 lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.6.1-java lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-2.6.1 lib/protobuf/rpc/servers/zmq_runner.rb