Start driving the chain, block until done

def run(self):
        """
        Start driving the chain, block until done
        """
        with self._run_lock:
            while self.mounts:
                for mount in self.mounts:
                    try:
                        next(mount)
                    except StopIteration:
                        self.mounts.remove(mount)