async def _make_request_queue(self) -> asyncio.Queue[quantum.QuantumRunStreamRequest | None]:
        """Returns a queue used to back the request iterator passed to the stream.

        If `None` is put into the queue, the request iterator will stop.
        """
        return asyncio.Queue(maxsize=100)
Returns a queue used to back the request iterator passed to the stream.

        If `None` is put into the queue, the request iterator will stop.
        
cirq-google/cirq_google/engine/stream_manager.py