Method acquire

trinity/buffer/writer/queue_writer.py:21–22

(self)

        return await self.queue.put_batch.remote(Experience.serialize_many(data))

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

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