Method stopped

trinity/buffer/storage/queue.py:179–181

Check if there is no more data to read.

(self)

        self._getters.clear()

    def stopped(self) -> bool:
        """Check if there is no more data to read."""
        return self._closed and self.empty()


class AsyncPriorityQueue(QueueBuffer):