class Async::Container::Supervisor::MemoryMonitor

def remove(connection)
	if process_id = connection.state[:process_id]
		connections = @processes[process_id]
		
		connections.delete(connection)
		
		if connections.empty?
			Console.debug(self, "Removing process:", process_id: process_id)
			@cluster.remove(process_id)
		end
	end
end