(ph.SrSSKJr SSKJr SSKJrJrJrJrJ r J r SSK r SSK J r SSKJr SS KJr SS KJr SS KJr S r"S S\S9r"SS\\S9r"SS\\\4\\S9r"SS\\\4\\S9r"SS\\\4\\S9r"SS\\\4\\S9rg)zAbstract base classes for client-side Call objects. Call objects represents the RPC itself, and offer methods to access / modify its information. They also offer methods to manipulate the life-cycle of the RPC, e.g. cancellation. )ABCMeta)abstractmethod)Any AsyncIterator GeneratorGenericOptionalUnionN)Metadata)DoneCallbackType)EOFType) RequestType) ResponseType) RpcContextCallUnaryUnaryCallUnaryStreamCallc\rSrSrSr\S\4Sj5r\S\4Sj5r\S\ \ 4Sj5r \S\4Sj5r \S\ SS 4S j5rS rg ) r$z,Provides RPC-related information and action.returncg)zReturn True if the RPC is cancelled. The RPC is cancelled when the cancellation was requested with cancel(). Returns: A bool indicates whether the RPC is cancelled or not. Nselfs F/var/www/html/venv/lib/python3.13/site-packages/grpc/aio/_base_call.py cancelledRpcContext.cancelled'cg)zReturn True if the RPC is done. An RPC is done if the RPC is completed, cancelled or aborted. Returns: A bool indicates if the RPC is done. Nrrs rdoneRpcContext.done1rr cg)aDescribes the length of allowed time remaining for the RPC. Returns: A nonnegative float indicating the length of allowed time in seconds remaining for the RPC to complete before it is considered to have timed out, or None if no deadline was specified for the RPC. Nrrs rtime_remainingRpcContext.time_remaining;rr cg)zCancels the RPC. Idempotent and has no effect if the RPC has already terminated. Returns: A bool indicates if the cancellation is performed or not. Nrrs rcancelRpcContext.cancelErr callbackNcg)zRegisters a callback to be called on RPC termination. Args: callback: A callable object will be called with the call object as its only argument. Nr)rr*s radd_done_callbackRpcContext.add_done_callbackOrr r)__name__ __module__ __qualname____firstlineno____doc__rboolrr"r floatr%r(r r,__static_attributes__rr rrr$s6 4   d         *: t  r r) metaclassc\rSrSrSr\S\4Sj5r\S\4Sj5r\S\ R4Sj5r \S\ 4Sj5r \S S j5rS rg) rYz5The abstract base class of an RPC on the client-side.rc # g7f)z\Accesses the initial metadata sent by the server. Returns: The initial :term:`metadata`. Nrrs rinitial_metadataCall.initial_metadata\c # g7f)z^Accesses the trailing metadata sent by the server. Returns: The trailing :term:`metadata`. Nrrs rtrailing_metadataCall.trailing_metadatadr<r=c # g7f)z[Accesses the status code sent by the server. Returns: The StatusCode value for the RPC. Nrrs rcode Call.codelr<r=c # g7f)zTAccesses the details sent by the server. Returns: The details string of the RPC. Nrrs rdetails Call.detailstr<r=Nc # g7f)a8Waits until connected to peer and raises aio.AioRpcError if failed. This is an EXPERIMENTAL method. This method ensures the RPC has been successfully connected. Otherwise, an AioRpcError will be raised to explain the reason of the connection failure. This method is recommended for building retry mechanisms. Nrrs rwait_for_connectionCall.wait_for_connection|r<r=rrN)r.r/r0r1r2rr r:r?grpc StatusCoderBstrrErHr5rr rrrYs?       DOO   s      r rc<\rSrSrSr\S\\S\44Sj5r Sr g)rz@The abstract base class of a unary-unary RPC on the client-side.rNcg)zUAwait the response message to be ready. Returns: The response message of the RPC. Nrrs r __await__UnaryUnaryCall.__await__rr r) r.r/r0r1r2rrrrrQr5rr rrrs-K 9S$ %<=  r rcT\rSrSr\S\\4Sj5r\S\\ \44Sj5r Sr g)rrcgzReturns the async iterator representation that yields messages. Under the hood, it is calling the "read" method. Returns: An async iterator object that yields messages. Nrrs r __aiter__UnaryStreamCall.__aiter__rr c # g7faReads one message from the stream. Read operations must be serialized when called from multiple coroutines. Note that the iterator and read/write APIs may not be mixed on a single RPC. Returns: A response message, or an `grpc.aio.EOF` to indicate the end of the stream. Nrrs rreadUnaryStreamCall.readr<r=rN) r.r/r0r1rrrrWr rr[r5rr rrrsG =6    E'<"78    r rch\rSrSr\S\SS4Sj5r\S Sj5r\S\\ S\ 44Sj5r Sr g) StreamUnaryCallrequestrNc # g7fzWrites one message to the stream. Note that the iterator and read/write APIs may not be mixed on a single RPC. Raises: An RpcError exception if the write failed. Nrrr`s rwriteStreamUnaryCall.writer<r=c # g7fzNotifies server that the client is done sending messages. After done_writing is called, any additional invocation to the write function will fail. This function is idempotent. Nrrs r done_writingStreamUnaryCall.done_writingr<r=cg)zXAwait the response message to be ready. Returns: The response message of the stream. Nrrs rrQStreamUnaryCall.__await__rr rrJ) r.r/r0r1rrrdrhrrrrQr5rr rr^r^s_ ; 4     9S$ %<=  r r^c\rSrSr\S\\4Sj5r\S\\ \44Sj5r \S\ SS4Sj5r \S Sj5r S rg) StreamStreamCallrcgrVrrs rrWStreamStreamCall.__aiter__rr c # g7frZrrs rr[StreamStreamCall.readr<r=r`Nc # g7frbrrcs rrdStreamStreamCall.writer<r=c # g7frgrrs rrhStreamStreamCall.done_writingr<r=rrJ)r.r/r0r1rrrrWr rr[rrdrhr5rr rrmrms} =6    E'<"78     ; 4    r rm)r2abcrrtypingrrrrr r rK _metadatar _typingr rrr__all__rrrrr^rmrr rr|sJJ % ! C2 72 j. :. b   K %&    K %& :  K %& >-  K %&- r