Class: Fluent::Counter::Handler

Inherits:

BaseSocket

• Object
• Coolio::TCPSocket
• BaseSocket
• Fluent::Counter::Handler

Defined in:

lib/fluent/counter/server.rb

Instance Method Summary

• #initialize(io, on_message) ⇒ Handler constructor

  A new instance of Handler.

• #on_message(data) ⇒ Object

Methods inherited from BaseSocket

#on_read, #packed_write

Constructor Details

#initialize(io, on_message) ⇒ Handler

Returns a new instance of Handler.

# File 'lib/fluent/counter/server.rb', line 262

def initialize(io, on_message)
  super(io)
  @on_message = on_message
end

Instance Method Details

#on_message(data) ⇒ Object

# File 'lib/fluent/counter/server.rb', line 267

def on_message(data)
  res = @on_message.call(data)
  packed_write res if res
end