Method write

trinity/buffer/writer/queue_writer.py:18–19

(self, data: List[Experience])

        self.queue = QueueStorage.get_wrapper(config)

    async def write(self, data: List[Experience]) -> None:
        return await self.queue.put_batch.remote(Experience.serialize_many(data))

    async def acquire(self) -> int:
        return await self.queue.acquire.remote()