o ae4@sdZddlZddlmZmZddlZddlmZddlm Z ddlm Z ddlm Z dd lm Z dd lm Z dd lmZGd d d ee e fejZGdddee e fejZGdddejZGdddejZGdddejZdS)zDAbstract base classes for Channel objects and Multicallable objects.N)GenericOptional) _base_call)DeserializingFunction) MetadataType)RequestIterableType) RequestType) ResponseType)SerializingFunctionc@leZdZdZejdddddddedeedee dee j dee d ee j d ejeeffd d ZdS) UnaryUnaryMultiCallablez4Enables asynchronous invocation of a unary-call RPC.Ntimeoutmetadata credentialswait_for_ready compressionrequestrrrrrreturncCdS)arAsynchronously invokes the underlying RPC. Args: request: The request value for the RPC. timeout: An optional duration of time in seconds to allow for the RPC. metadata: Optional :term:`metadata` to be transmitted to the service-side of the RPC. credentials: An optional CallCredentials for the RPC. Only valid for secure Channel. wait_for_ready: An optional flag to enable :term:`wait_for_ready` mechanism. compression: An element of grpc.compression, e.g. grpc.compression.Gzip. Returns: A UnaryUnaryCall object. Raises: RpcError: Indicates that the RPC terminated with non-OK status. The raised RpcError will also be a Call for the RPC affording the RPC's metadata, status code, and details. NselfrrrrrrrrFD:\Projects\ConvertPro\env\Lib\site-packages\grpc/aio/_base_channel.py__call__!z UnaryUnaryMultiCallable.__call__)__name__ __module__ __qualname____doc__abcabstractmethodr rfloatrgrpcCallCredentialsbool CompressionrZUnaryUnaryCallr rrrrrr . r c@r ) UnaryStreamMultiCallablez:Enables asynchronous invocation of a server-streaming RPC.NrrrrrrrrcCr)asAsynchronously invokes the underlying RPC. Args: request: The request value for the RPC. timeout: An optional duration of time in seconds to allow for the RPC. metadata: Optional :term:`metadata` to be transmitted to the service-side of the RPC. credentials: An optional CallCredentials for the RPC. Only valid for secure Channel. wait_for_ready: An optional flag to enable :term:`wait_for_ready` mechanism. compression: An element of grpc.compression, e.g. grpc.compression.Gzip. Returns: A UnaryStreamCall object. Raises: RpcError: Indicates that the RPC terminated with non-OK status. The raised RpcError will also be a Call for the RPC affording the RPC's metadata, status code, and details. NrrrrrrGrz!UnaryStreamMultiCallable.__call__)rrrr r!r"r rr#rr$r%r&r'rZUnaryStreamCallr rrrrrr)Dr(r)c@heZdZdZej      d deedeedee dee j dee dee j d ejfd d ZdS) StreamUnaryMultiCallablez:Enables asynchronous invocation of a client-streaming RPC.Nrequest_iteratorrrrrrrcCr)aAsynchronously invokes the underlying RPC. Args: request_iterator: An optional async iterable or iterable of request messages for the RPC. timeout: An optional duration of time in seconds to allow for the RPC. metadata: Optional :term:`metadata` to be transmitted to the service-side of the RPC. credentials: An optional CallCredentials for the RPC. Only valid for secure Channel. wait_for_ready: An optional flag to enable :term:`wait_for_ready` mechanism. compression: An element of grpc.compression, e.g. grpc.compression.Gzip. Returns: A StreamUnaryCall object. Raises: RpcError: Indicates that the RPC terminated with non-OK status. The raised RpcError will also be a Call for the RPC affording the RPC's metadata, status code, and details. Nrrr,rrrrrrrrrmrz!StreamUnaryMultiCallable.__call__NNNNNN)rrrr r!r"rrr#rr$r%r&r'rZStreamUnaryCallrrrrrr+j0r+c@r*) StreamStreamMultiCallablezAEnables asynchronous invocation of a bidirectional-streaming RPC.Nr,rrrrrrcCr)aAsynchronously invokes the underlying RPC. Args: request_iterator: An optional async iterable or iterable of request messages for the RPC. timeout: An optional duration of time in seconds to allow for the RPC. metadata: Optional :term:`metadata` to be transmitted to the service-side of the RPC. credentials: An optional CallCredentials for the RPC. Only valid for secure Channel. wait_for_ready: An optional flag to enable :term:`wait_for_ready` mechanism. compression: An element of grpc.compression, e.g. grpc.compression.Gzip. Returns: A StreamStreamCall object. Raises: RpcError: Indicates that the RPC terminated with non-OK status. The raised RpcError will also be a Call for the RPC affording the RPC's metadata, status code, and details. Nrr-rrrrrz"StreamStreamMultiCallable.__call__r.)rrrr r!r"rrr#rr$r%r&r'rZStreamStreamCallrrrrrr0r/r0c @sFeZdZdZejddZejddZejddee fdd Z ej d d e d e j fd dZejde j d dfddZejd!ddZej  d"dedeedeed efddZej  d"dedeedeed efddZej  d"dedeedeed efddZej  d"dedeedeed efddZdS)#ChannelzEnables asynchronous RPC invocation as a client. Channel objects implement the Asynchronous Context Manager (aka. async with) type, although they are not supportted to be entered and exited multiple times. cdS)zwStarts an asynchronous context manager. Returns: Channel the channel that was instantiated. Nrrrrr __aenter__zChannel.__aenter__cr2)zxFinishes the asynchronous context manager by closing the channel. Still active RPCs will be cancelled. Nr)rexc_typeexc_valexc_tbrrr __aexit__r5zChannel.__aexit__Ngracecr2)aCloses this Channel and releases all resources held by it. This method immediately stops the channel from executing new RPCs in all cases. If a grace period is specified, this method wait until all active RPCs are finshed, once the grace period is reached the ones that haven't been terminated are cancelled. If a grace period is not specified (by passing None for grace), all existing RPCs are cancelled immediately. This method is idempotent. Nr)rr:rrrcloser5z Channel.closeFtry_to_connectrcCr)aChecks the connectivity state of a channel. This is an EXPERIMENTAL API. If the channel reaches a stable connectivity state, it is guaranteed that the return value of this function will eventually converge to that state. Args: try_to_connect: a bool indicate whether the Channel should try to connect to peer or not. Returns: A ChannelConnectivity object. Nr)rr<rrr get_staterzChannel.get_statelast_observed_statecr2)aWaits for a change in connectivity state. This is an EXPERIMENTAL API. The function blocks until there is a change in the channel connectivity state from the "last_observed_state". If the state is already different, this function will return immediately. There is an inherent race between the invocation of "Channel.wait_for_state_change" and "Channel.get_state". The state can change arbitrary many times during the race, so there is no way to observe every state transition. If there is a need to put a timeout for this function, please refer to "asyncio.wait_for". Args: last_observed_state: A grpc.ChannelConnectivity object representing the last known state. Nr)rr>rrrwait_for_state_changer5zChannel.wait_for_state_changecr2)z;Creates a coroutine that blocks until the Channel is READY.Nrr3rrr channel_ready r5zChannel.channel_readymethodrequest_serializerresponse_deserializercCr)a0Creates a UnaryUnaryMultiCallable for a unary-unary method. Args: method: The name of the RPC method. request_serializer: Optional :term:`serializer` for serializing the request message. Request goes unserialized in case None is passed. response_deserializer: Optional :term:`deserializer` for deserializing the response message. Response goes undeserialized in case None is passed. Returns: A UnaryUnaryMultiCallable value for the named unary-unary method. NrrrArBrCrrr unary_unary rzChannel.unary_unarycCr)a4Creates a UnaryStreamMultiCallable for a unary-stream method. Args: method: The name of the RPC method. request_serializer: Optional :term:`serializer` for serializing the request message. Request goes unserialized in case None is passed. response_deserializer: Optional :term:`deserializer` for deserializing the response message. Response goes undeserialized in case None is passed. Returns: A UnarySteramMultiCallable value for the named unary-stream method. NrrDrrr unary_stream"rzChannel.unary_streamcCr)a4Creates a StreamUnaryMultiCallable for a stream-unary method. Args: method: The name of the RPC method. request_serializer: Optional :term:`serializer` for serializing the request message. Request goes unserialized in case None is passed. response_deserializer: Optional :term:`deserializer` for deserializing the response message. Response goes undeserialized in case None is passed. Returns: A StreamUnaryMultiCallable value for the named stream-unary method. NrrDrrr stream_unary7rzChannel.stream_unarycCr)a8Creates a StreamStreamMultiCallable for a stream-stream method. Args: method: The name of the RPC method. request_serializer: Optional :term:`serializer` for serializing the request message. Request goes unserialized in case None is passed. response_deserializer: Optional :term:`deserializer` for deserializing the response message. Response goes undeserialized in case None is passed. Returns: A StreamStreamMultiCallable value for the named stream-stream method. NrrDrrr stream_streamLrzChannel.stream_stream)N)F)rN)NN)rrrr r!r"r4r9rr#r;r&r$ZChannelConnectivityr=r?r@strr rr rEr)rFr+rGr0rHrrrrr1s        r1)r r!typingrrr$rZ_typingrrrr r r ABCr r)r+r0r1rrrrs         &&&&