(phE6fSrSSKrSSKJrJr SSKrSSKJr SSKJ r SSKJ r SSKJ r SS KJ r SS KJ r SS KJr "S S \\ \ 4\R5r"SS\\ \ 4\R5r"SS\R5r"SS\R5r"SS\R5rg)zDAbstract base classes for Channel objects and Multicallable objects.N)GenericOptional) _base_call)DeserializingFunction) MetadataType)RequestIterableType) RequestType) ResponseType)SerializingFunctionc\rSrSrSr\R SSSSSS.S\S\\ S\\ S\\ RS \\ S \\ RS \R \\44S jj5rS rg)UnaryUnaryMultiCallablez4Enables asynchronous invocation of a unary-call RPC.Ntimeoutmetadata credentialswait_for_ready compressionrequestrrrrrreturncg)aAsynchronously 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. Nselfrrrrrrs I/var/www/html/venv/lib/python3.13/site-packages/grpc/aio/_base_channel.py__call__ UnaryUnaryMultiCallable.__call__!r)__name__ __module__ __qualname____firstlineno____doc__abcabstractmethodr rfloatrgrpcCallCredentialsbool CompressionrUnaryUnaryCallr r__static_attributes__rr rrrs> $(+/6:)-26  %  <(  d223  ! d../   " "; #< =  r rc\rSrSrSr\R SSSSSS.S\S\\ S\\ S\\ RS \\ S \\ RS \R \\44S jj5rS rg)UnaryStreamMultiCallableDz:Enables asynchronous invocation of a server-streaming RPC.Nrrrrrrrrcg)aAsynchronously 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. Nrrs rr!UnaryStreamMultiCallable.__call__Grr r)r!r"r#r$r%r&r'r rr(rr)r*r+r,rUnaryStreamCallr rr.rr rr0r0DsD $(+/6:)-26  %  <(  d223  ! d../   # #K$= >  r r0c\rSrSrSr\R S S\\S\\ S\\ S\\ RS\\ S \\ RS \R 4S jj5rS rg)StreamUnaryMultiCallablejz:Enables asynchronous invocation of a client-streaming RPC.Nrequest_iteratorrrrrrrcg)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. Nrrr8rrrrrs rr!StreamUnaryMultiCallable.__call__mrr rNNNNNN)r!r"r#r$r%r&r'rr r(rr)r*r+r,rStreamUnaryCallrr.rr rr6r6jsD;?#'+/6:)-26 "#67 % <(  d223  !  d../   # #  r r6c\rSrSrSr\R S S\\S\\ S\\ S\\ RS\\ S \\ RS \R 4S jj5rS rg)StreamStreamMultiCallablezAEnables asynchronous invocation of a bidirectional-streaming RPC.Nr8rrrrrrcg)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:s rr"StreamStreamMultiCallable.__call__rr rr<)r!r"r#r$r%r&r'rr r(rr)r*r+r,rStreamStreamCallrr.rr rr?r?sK;?#'+/6:)-26 "#67 % <(  d223  !  d../   $ $  r r?c \rSrSrSr\R S5r\R S5r\R SS\ \ 4Sjj5r \R SS\ S \ R4S jj5r\R S \ RS S4S j5r\R SS j5r\R SS\S\ \S\ \S\ \ S \4 Sjj5r\R SS\S\ \S\ \S\ \ S \4 Sjj5r\R SS\S\ \S\ \S\ \ S \4 Sjj5r\R SS\S\ \S\ \S\ \ S \4 Sjj5rSrg)ChannelzEnables asynchronous RPC invocation as a client. Channel objects implement the Asynchronous Context Manager (aka. async with) type, although they are not supported to be entered and exited multiple times. c # g7f)z_Starts an asynchronous context manager. Returns: Channel the channel that was instantiated. Nrrs r __aenter__Channel.__aenter__c # g7f)zhFinishes the asynchronous context manager by closing the channel. Still active RPCs will be cancelled. Nr)rexc_typeexc_valexc_tbs r __aexit__Channel.__aexit__rKrLNgracec # g7f)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 waits until all active RPCs are finished or until the grace period is reached. RPCs that haven't been terminated within the grace period are aborted. If a grace period is not specified (by passing None for grace), all existing RPCs are cancelled immediately. This method is idempotent. Nr)rrSs rclose Channel.closerKrLtry_to_connectrcg)anChecks 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)rrWs r get_stateChannel.get_staterr last_observed_statec # g7f)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[s rwait_for_state_changeChannel.wait_for_state_changerKrLc # g7f)z;Creates a coroutine that blocks until the Channel is READY.NrrHs r channel_readyChannel.channel_ready rKrLmethodrequest_serializerresponse_deserializer_registered_methodcg)aRCreates 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. _registered_method: Implementation Private. Optional: A bool representing whether the method is registered. Returns: A UnaryUnaryMultiCallable value for the named unary-unary method. Nrrrbrcrdres r unary_unaryChannel.unary_unaryrr cg)aVCreates 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. _registered_method: Implementation Private. Optional: A bool representing whether the method is registered. Returns: A UnaryStreamMultiCallable value for the named unary-stream method. Nrrgs r unary_streamChannel.unary_stream&rr cg)aVCreates 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. _registered_method: Implementation Private. Optional: A bool representing whether the method is registered. Returns: A StreamUnaryMultiCallable value for the named stream-unary method. Nrrgs r stream_unaryChannel.stream_unary>rr cg)aZCreates 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. _registered_method: Implementation Private. Optional: A bool representing whether the method is registered. Returns: A StreamStreamMultiCallable value for the named stream-stream method. Nrrgs r stream_streamChannel.stream_streamVrr r)N)F)rN)NNF)r!r"r#r$r%r&r'rIrQrr(rUr+r)ChannelConnectivityrYr]r`strr rrrhr0rkr6rnr?rqr.rr rrErEsy         %     %* " ! !  $  !55    2 JJ =AAE-2   %%89  ((=>  %TN  !   . =AAE-2   %%89  ((=>  %TN  "   . =AAE-2   %%89  ((=>  %TN  "   . =AAE-2   %%89  ((=>  %TN  #   r rE)r%r&typingrrr)r_typingrrr r r r ABCrr0r6r?rErr rrysK $ *!( !(# gk<&?@#''# L# w{L'@A377# L# sww# L# # Lv cggv r