class Async::HTTP::Mock::Endpoint

def run(parent: Task.current, &block)
	while peer = @queue.dequeue
		server = @protocol.server(peer)
		
		parent.async do
			server.each(&block)
		end
	end
end