async def _request_iterator(
    request_queue: asyncio.Queue[quantum.QuantumRunStreamRequest | None],
) -> AsyncIterator[quantum.QuantumRunStreamRequest]:
    """The request iterator for Quantum Engine client RPC quantum_run_stream().

    Every call to this method generates a new iterator.
    """
    while request := await request_queue.get():
        yield request
The request iterator for Quantum Engine client RPC quantum_run_stream().

    Every call to this method generates a new iterator.
    
cirq-google/cirq_google/engine/stream_manager.py