Class: Protobuf::Rpc::SocketRunner

Inherits:
Object
  • Object
show all
Defined in:
lib/protobuf/rpc/servers/socket_runner.rb

Instance Method Summary collapse

Constructor Details

#initialize(options) ⇒ SocketRunner

Returns a new instance of SocketRunner.



11
12
13
14
15
16
17
18
19
20
21
22
 
# 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

Instance Method Details

#run ⇒ Object 



24
25
26
27
 
# File 'lib/protobuf/rpc/servers/socket_runner.rb', line 24

def run
  yield if block_given?
  server.run
end

#running? ⇒ Boolean

Returns:

  • (Boolean) 


29
30
31
 
# File 'lib/protobuf/rpc/servers/socket_runner.rb', line 29

def running?
  server.running?
end

#stop ⇒ Object 



33
34
35
 
# File 'lib/protobuf/rpc/servers/socket_runner.rb', line 33

def stop
  server.stop
end