class Fluent::PluginHelper::HttpServer::Server

def start(notify = nil)
  @logger.debug("Start async HTTP server listening #{@uri}")
  task = @reactor.run do
    @server.run
    if notify
      notify.push(:ready)
    end
  end
  task.stop
  @logger.debug('Finished HTTP server')
end