class Async::Container::Supervisor::Client

def run
	Async do
		loop do
			connection = connect!
			
			Async do
				connected!(connection)
			end
			
			connection.run(self)
		rescue => error
			Console.error(self, "Connection failed:", exception: error)
			sleep(rand)
		ensure
			connection&.close
		end
	end
end