async def wait_for_requests(self, num_requests=1) -> Sequence[quantum.QuantumRunStreamRequest]:
        """Wait til `num_requests` number of requests are received via `quantum_run_stream()`.

        This must be called from the duet thread.

        Returns:
            The received requests.
        """
        requests = []
        for _ in range(num_requests):
            requests.append(await self._request_buffer.__anext__())
        return requests
Wait til `num_requests` number of requests are received via `quantum_run_stream()`.

        This must be called from the duet thread.

        Returns:
            The received requests.
        
cirq-google/cirq_google/engine/stream_manager_test.py