class Falcon::Supervisor

def run
	Async.logger.info("Binding to #{@endpoint}")
	@endpoint.accept do |peer|
		stream = Async::IO::Stream.new(peer)
		
		while message = stream.gets("\0")
			response = handle(JSON.parse(message, symbolize_names: true))
			stream.puts(response.to_json, separator: "\0")
		end
	end
end