class Protobuf::Rpc::SocketRunner

Attributes

server[RW]

Private Class Methods

new(options) click to toggle source
# File lib/protobuf/rpc/servers/socket_runner.rb, line 11
def initialize(options)
  options = case
            when options.is_a?(OpenStruct) then
              options.marshal_dump
            when options.respond_to?(:to_hash) then
              options.to_hash.symbolize_keys
            else
              fail "Cannot parser Socket Server - server options"
            end

  self.server = ::Protobuf::Rpc::Socket::Server.new(options)
end

Private Instance Methods

run() { || ... } click to toggle source
# File lib/protobuf/rpc/servers/socket_runner.rb, line 24
def run
  yield if block_given?
  server.run
end
running?() click to toggle source
# File lib/protobuf/rpc/servers/socket_runner.rb, line 29
def running?
  server.running?
end
stop() click to toggle source
# File lib/protobuf/rpc/servers/socket_runner.rb, line 33
def stop
  server.stop
end