a v=ic­3ã@s¾dZddlZddlmZmZddlZddlmZddlm Z ddlm Z ddlm Z dd lm Z Gd d „d ej ƒZGd d „d ej ƒZGdd„dej ƒZGdd„dej ƒZGdd„dej ƒZdS)zDAbstract base classes for Channel objects and Multicallable objects.éN)ÚAnyÚOptionalé)Ú _base_call)ÚDeserializingFunction)Ú MetadataType)ÚRequestIterableType)ÚSerializingFunctionc @sXeZdZdZejddddddœeeeee ee j ee ee j ejdœdd„ƒZdS)ÚUnaryUnaryMultiCallablez4Enables asynchronous invocation of a unary-call RPC.N©ÚtimeoutÚmetadataÚ credentialsÚwait_for_readyÚ compression©Úrequestr r rrrÚreturncCsdS)aÀAsynchronously 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: This is an EXPERIMENTAL argument. An optional flag to enable :term:`wait_for_ready` mechanism. compression: An element of grpc.compression, e.g. grpc.compression.Gzip. This is an EXPERIMENTAL option. 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. N©©Úselfrr r rrrrrúg/home/droni/.local/share/virtualenvs/DPS-5Je3_V2c/lib/python3.9/site-packages/grpc/aio/_base_channel.pyÚ__call__s z UnaryUnaryMultiCallable.__call__)Ú__name__Ú __module__Ú __qualname__Ú__doc__ÚabcÚabstractmethodrrÚfloatrÚgrpcÚCallCredentialsÚboolÚ CompressionrZUnaryUnaryCallrrrrrr s ø÷r c @sXeZdZdZejddddddœeeeee ee j ee ee j ejdœdd„ƒZdS)ÚUnaryStreamMultiCallablez:Enables asynchronous invocation of a server-streaming RPC.Nr rcCsdS)aÁAsynchronously 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: This is an EXPERIMENTAL argument. An optional flag to enable :term:`wait_for_ready` mechanism. compression: An element of grpc.compression, e.g. grpc.compression.Gzip. This is an EXPERIMENTAL option. 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. NrrrrrrFs z!UnaryStreamMultiCallable.__call__)rrrrrrrrrrr r!r"r#rZUnaryStreamCallrrrrrr$Cs ø÷r$c @sPeZdZdZejdeeeeee ee j ee ee j ejdœdd„ƒZdS)ÚStreamUnaryMultiCallablez:Enables asynchronous invocation of a client-streaming RPC.N©Úrequest_iteratorr r rrrrcCsdS)aÿAsynchronously 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: This is an EXPERIMENTAL argument. An optional flag to enable :term:`wait_for_ready` mechanism. compression: An element of grpc.compression, e.g. grpc.compression.Gzip. This is an EXPERIMENTAL option. 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. Nr©rr'r r rrrrrrrms z!StreamUnaryMultiCallable.__call__)NNNNNN)rrrrrrrrrrr r!r"r#rZStreamUnaryCallrrrrrr%js"ùør%c @sPeZdZdZejdeeeeee ee j ee ee j ejdœdd„ƒZdS)ÚStreamStreamMultiCallablezAEnables asynchronous invocation of a bidirectional-streaming RPC.Nr&cCsdS)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: This is an EXPERIMENTAL argument. An optional flag to enable :term:`wait_for_ready` mechanism. compression: An element of grpc.compression, e.g. grpc.compression.Gzip. This is an EXPERIMENTAL option. 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(rrrr”s z"StreamStreamMultiCallable.__call__)NNNNNN)rrrrrrrrrrr r!r"r#rZStreamStreamCallrrrrrr)‘s"ùør)c@seZdZdZejdd„ƒZejdd„ƒZejdee dœdd „ƒZ ejde e j d œd d „ƒZeje j ddœdd„ƒZejddœdd„ƒZejdeeeeeedœdd„ƒZejd eeeeeedœdd„ƒZejd!eeeeeedœdd„ƒZejd"eeeeeedœdd„ƒZdS)#ÚChannelzßEnables 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. cÃsdS)zwStarts an asynchronous context manager. Returns: Channel the channel that was instantiated. Nr©rrrrÚ __aenter__ÀszChannel.__aenter__cÃsdS)zxFinishes the asynchronous context manager by closing the channel. Still active RPCs will be cancelled. Nr)rÚexc_typeÚexc_valÚexc_tbrrrÚ __aexit__ÈszChannel.__aexit__N)ÚgracecÃsdS)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)rr1rrrÚcloseÏsz Channel.closeF)Útry_to_connectrcCsdS)a¶Checks 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)rr3rrrÚ get_stateÞszChannel.get_state)Úlast_observed_statercÃsdS)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)rr5rrrÚwait_for_state_changeðszChannel.wait_for_state_change)rcÃsdS)z;Creates a coroutine that blocks until the Channel is READY.Nrr+rrrÚ channel_ready szChannel.channel_ready)ÚmethodÚrequest_serializerÚresponse_deserializerrcCsdS)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. Nr©rr8r9r:rrrÚ unary_unaryszChannel.unary_unarycCsdS)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. Nrr;rrrÚ unary_stream#szChannel.unary_streamcCsdS)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. Nrr;rrrÚ stream_unary8szChannel.stream_unarycCsdS)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. Nrr;rrrÚ stream_streamMszChannel.stream_stream)N)F)NN)NN)NN)NN)rrrrrrr,r0rrr2r"r ZChannelConnectivityr4r6r7Ústrr rr r<r$r=r%r>r)r?rrrrr*¸sl  ÿÿýüûüûüûüûr*)rrÚtypingrrr ÚrZ_typingrrrr ÚABCr r$r%r)r*rrrrÚs     ''''