Method read

trinity/buffer/task_scheduler.py:76–77

(self)

        self.reader = get_buffer_reader(taskset_config)

    async def read(self) -> List:
        return await self.reader.read()

    def state_dict(self) -> List[Dict]:
        return [self.reader.state_dict()]