Module: cirq_google.engine.stream_manager

Classes

class ResponseDemux: An event demultiplexer for QuantumRunStreamResponses, as part of the async reactor pattern.

class StreamError: Common base class for all non-exit exceptions.

class StreamManager: Manages communication with Quantum Engine via QuantumRunStream, a bi-directional stream RPC.

RETRYABLE_GOOGLE_API_EXCEPTIONS [<class 'google.api_core.exceptions.InternalServerError'>, <class 'google.api_core.exceptions.ServiceUnavailable'>]