Method write_blocking_call

tests/buffer/queue_test.py:212–223

()

        # should be blocked
        def write_blocking_call():
            asyncio.run(
                writer.write(
                    [
                        Experience(
                            tokens=torch.tensor([1, 2, 3]),
                            prompt_length=2,
                            info={"model_version": 4, "use_count": 0},
                        )
                    ]
                )
            )

        thread = threading.Thread(target=write_blocking_call)
        thread.start()