Method drained

CV/PaddleReid/reid/data/parallel_map.py:184–186

(self)

                break

    def drained(self):
        assert self._epoch >= 0, "first epoch has not started yet"
        return self._source.drained() and self._produced == self._consumed

    def stop(self):
        """ notify to exit