Module: RightScale::CommandIO::ServerInputHandler
- Defined in:
- lib/right_agent/command/command_io.rb
Overview
EventMachine connection Define event loop callbacks handler
Instance Method Summary collapse
-
#initialize(handler) ⇒ Object
Keep block used to handle incoming data.
-
#receive_data(data) ⇒ Object
EventMachine loop callback called whenever there is data coming from the socket.
Instance Method Details
#initialize(handler) ⇒ Object
Keep block used to handle incoming data
Parameters
- handler(Proc)
-
Incoming data handler should take two arguments:
* First argument contains command * Second argument contains connection used to reply
34 35 36 37 |
# File 'lib/right_agent/command/command_io.rb', line 34 def initialize(handler) @handler = handler @parser = CommandParser.new { |cmd| handler.call(cmd, self) } end |
#receive_data(data) ⇒ Object
EventMachine loop callback called whenever there is data coming from the socket
Parameter
- data(String)
-
Incoming data
Return
- true
-
Always return true
46 47 48 49 |
# File 'lib/right_agent/command/command_io.rb', line 46 def receive_data(data) @parser.parse_chunk(data) true end |