async def results_async(self) -> Sequence[EngineResult]:
        """Returns the job results, blocking until the job is complete."""
        if self._type == LocalSimulationType.SYNCHRONOUS:
            return _flatten_results(self._execute_results())
        elif self._type == LocalSimulationType.ASYNCHRONOUS:
            return _flatten_results(await self._future)
        else:
            raise ValueError('Unsupported simulation type {self._type}')
Returns the job results, blocking until the job is complete.
cirq-google/cirq_google/engine/simulated_local_job.py