Method read

trinity/buffer/storage/file.py:68–71

(self)

        self.file.flush()

    def read(self) -> List:
        raise NotImplementedError(
            "read() is not implemented for FILE Storage, please use QUEUE instead"
        )

    def acquire(self) -> int:
        self.ref_count += 1