class Fluent::StreamInput

def start
  super
  @loop = Coolio::Loop.new
  @lsock = listen
  @loop.attach(@lsock)
  @thread = Thread.new(&method(:run))
end