ruạṛ
a K��fz� � @ s� d Z ddlmZ ddlmZ ddlZddlZddlZddlmZm Z m Z m Z m Z m Z mZmZ ddlZddlmZ ddlmZ dd lmZ dd lmZ dd lmZ dd lmZ dd lmZ ddlmZ ddlm Z ddlm Z ddl m Z ddl m!Z! ddl m"Z" ddl m#Z# ddl m$Z$ ddl m%Z% ddl m&Z& ddl m'Z' ddl m(Z( ddl)m*Z* dZ+G d d � d ed �Z,G d d � d e�-d d!�ej.�Z.G d"d#� d#ed �Z/G d$d%� d%e/ed �Z0G d&d'� d'e/ed �Z1G d(d)� d)e/ed �Z2G d*d+� d+e/ed �Z3G d,d-� d-�Z4G d.d/� d/�Z5G d0d1� d1�Z6G d2d3� d3�Z7G d4d5� d5e5e4ej�Z8G d6d7� d7e6e4ej�Z9G d8d9� d9e5e7e4ej�Z:G d:d;� d;e6e7e4ej�Z;G d<d=� d=ej�Z<G d>d?� d?�Z=G d@dA� dAe=ej�Z>G dBdC� dCe=ej�Z?dS )Dz3Interceptors implementation of gRPC Asyncio Python.� )�ABCMeta)�abstractmethodN)� AsyncIterable� Awaitable�Callable�Iterator�List�Optional�Sequence�Union)�cygrpc� )� _base_call)� AioRpcError)�StreamStreamCall)�StreamUnaryCall)�UnaryStreamCall)�UnaryUnaryCall)�_API_STYLE_ERROR)� _RPC_ALREADY_FINISHED_DETAILS)�_RPC_HALF_CLOSED_DETAILS)�Metadata)�DeserializingFunction)�DoneCallbackType)�EOFType)�RequestIterableType)� RequestType)�ResponseIterableType)� ResponseType)�SerializingFunction)�_timeout_to_deadlinez!Locally cancelled by application!c @ s< e Zd ZdZeeejgeej f ejej d�dd��Z dS )�ServerInterceptorz^Affords intercepting incoming RPCs on the service-side. This is an EXPERIMENTAL API. )� continuation�handler_call_details�returnc � s dS )aA Intercepts incoming RPCs before handing them over to a handler. State can be passed from an interceptor to downstream interceptors via contextvars. The first interceptor is called from an empty contextvars.Context, and the same Context is used for downstream interceptors and for the final handler call. Note that there are no guarantees that interceptors and handlers will be called from the same thread. Args: continuation: A function that takes a HandlerCallDetails and proceeds to invoke the next interceptor in the chain, if any, or the RPC handler lookup logic, with the call details passed as an argument, and returns an RpcMethodHandler instance if the RPC is considered serviced, or None otherwise. handler_call_details: A HandlerCallDetails describing the RPC. Returns: An RpcMethodHandler with which the RPC may be serviced if the interceptor chooses to service this RPC, or None otherwise. N� )�selfr" r# r% r% �y/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/grpc/aio/_interceptor.py�intercept_service? s z#ServerInterceptor.intercept_serviceN) �__name__� __module__� __qualname__�__doc__r r �grpc�HandlerCallDetailsr �RpcMethodHandlerr( r% r% r% r' r! 9 s ��r! )� metaclassc @ sL e Zd ZU dZeed< ee ed< ee ed< ee j ed< ee ed< dS )�ClientCallDetailsa� Describes an RPC to be invoked. This is an EXPERIMENTAL API. Args: method: The method name of the RPC. timeout: An optional duration of time in seconds to allow for the RPC. metadata: Optional metadata to be transmitted to the service-side of the RPC. credentials: An optional CallCredentials for the RPC. wait_for_ready: An optional flag to enable :term:`wait_for_ready` mechanism. �method�timeout�metadata� credentials�wait_for_readyN) r) r* r+ r, �str�__annotations__r �floatr r- �CallCredentials�boolr% r% r% r' r1 ^ s r1 )r2 r3 r4 r5 r6 c @ s e Zd ZdZdS )�ClientInterceptorz6Base class used for all Aio Client Interceptor classesN)r) r* r+ r, r% r% r% r' r< y s r< c @ s< e Zd ZdZeeeegef eee ee f d�dd��Z dS )�UnaryUnaryClientInterceptorz-Affords intercepting unary-unary invocations.�r" �client_call_details�requestr$ c � s dS )a� Intercepts a unary-unary invocation asynchronously. Args: continuation: A coroutine that proceeds with the invocation by executing the next interceptor in the chain or invoking the actual RPC on the underlying Channel. It is the interceptor's responsibility to call it if it decides to move the RPC forward. The interceptor can use `call = await continuation(client_call_details, request)` to continue with the RPC. `continuation` returns the call to the RPC. client_call_details: A ClientCallDetails object describing the outgoing RPC. request: The request value for the RPC. Returns: An object with the RPC response. Raises: AioRpcError: Indicating that the RPC terminated with non-OK status. asyncio.CancelledError: Indicating that the RPC was canceled. Nr% �r& r" r? r@ r% r% r' �intercept_unary_unary� s z1UnaryUnaryClientInterceptor.intercept_unary_unaryN) r) r* r+ r, r r r1 r r r r rB r% r% r% r' r= } s � �r= c @ s< e Zd ZdZeeeegef eee e ef d�dd��Z dS )� UnaryStreamClientInterceptorz.Affords intercepting unary-stream invocations.r> c � s dS )a� Intercepts a unary-stream invocation asynchronously. The function could return the call object or an asynchronous iterator, in case of being an asyncrhonous iterator this will become the source of the reads done by the caller. Args: continuation: A coroutine that proceeds with the invocation by executing the next interceptor in the chain or invoking the actual RPC on the underlying Channel. It is the interceptor's responsibility to call it if it decides to move the RPC forward. The interceptor can use `call = await continuation(client_call_details, request)` to continue with the RPC. `continuation` returns the call to the RPC. client_call_details: A ClientCallDetails object describing the outgoing RPC. request: The request value for the RPC. Returns: The RPC Call or an asynchronous iterator. Raises: AioRpcError: Indicating that the RPC terminated with non-OK status. asyncio.CancelledError: Indicating that the RPC was canceled. Nr% rA r% r% r' �intercept_unary_stream� s z3UnaryStreamClientInterceptor.intercept_unary_streamN) r) r* r+ r, r r r1 r r r r rD r% r% r% r' rC � s � �rC c @ s4 e Zd ZdZeeeegef ee ed�dd��Z dS )� StreamUnaryClientInterceptorz.Affords intercepting stream-unary invocations.�r" r? �request_iteratorr$ c � s dS )a� Intercepts a stream-unary invocation asynchronously. Within the interceptor the usage of the call methods like `write` or even awaiting the call should be done carefully, since the caller could be expecting an untouched call, for example for start writing messages to it. Args: continuation: A coroutine that proceeds with the invocation by executing the next interceptor in the chain or invoking the actual RPC on the underlying Channel. It is the interceptor's responsibility to call it if it decides to move the RPC forward. The interceptor can use `call = await continuation(client_call_details, request_iterator)` to continue with the RPC. `continuation` returns the call to the RPC. client_call_details: A ClientCallDetails object describing the outgoing RPC. request_iterator: The request iterator that will produce requests for the RPC. Returns: The RPC Call. Raises: AioRpcError: Indicating that the RPC terminated with non-OK status. asyncio.CancelledError: Indicating that the RPC was canceled. Nr% �r& r" r? rG r% r% r' �intercept_stream_unary� s z3StreamUnaryClientInterceptor.intercept_stream_unaryN) r) r* r+ r, r r r1 r r r rI r% r% r% r' rE � s ��rE c @ s< e Zd ZdZeeeegef ee e e ef d�dd��Z dS )� StreamStreamClientInterceptorz/Affords intercepting stream-stream invocations.rF c � s dS )a� Intercepts a stream-stream invocation asynchronously. Within the interceptor the usage of the call methods like `write` or even awaiting the call should be done carefully, since the caller could be expecting an untouched call, for example for start writing messages to it. The function could return the call object or an asynchronous iterator, in case of being an asyncrhonous iterator this will become the source of the reads done by the caller. Args: continuation: A coroutine that proceeds with the invocation by executing the next interceptor in the chain or invoking the actual RPC on the underlying Channel. It is the interceptor's responsibility to call it if it decides to move the RPC forward. The interceptor can use `call = await continuation(client_call_details, request_iterator)` to continue with the RPC. `continuation` returns the call to the RPC. client_call_details: A ClientCallDetails object describing the outgoing RPC. request_iterator: The request iterator that will produce requests for the RPC. Returns: The RPC Call or an asynchronous iterator. Raises: AioRpcError: Indicating that the RPC terminated with non-OK status. asyncio.CancelledError: Indicating that the RPC was canceled. Nr% rH r% r% r' �intercept_stream_stream� s z5StreamStreamClientInterceptor.intercept_stream_streamN) r) r* r+ r, r r r1 r r r r r rK r% r% r% r' rJ � s � �rJ c @ s e Zd ZU dZejed< ee ed< ejdd�dd�Z dd � Z ejdd�d d �Z ee j dd �d d�Zed�dd�Zed�dd�Zed�dd�Zedd�dd�Zee d�dd�Zee d�dd �Zee d�d d �Zejd�d d �Z e d�d!d"�Z ee d�d#d$�Z dd�d%d&�Z dS )'�InterceptedCallaE Base implementation for all intercepted call arities. Interceptors might have some work to do before the RPC invocation with the capacity of changing the invocation parameters, and some work to do after the RPC invocation with the capacity for accessing to the wrapped `UnaryUnaryCall`. It handles also early and later cancellations, when the RPC has not even started and the execution is still held by the interceptors or when the RPC has finished but again the execution is still held by the interceptors. Once the RPC is finally executed, all methods are finally done against the intercepted call, being at the same time the same call returned to the interceptors. As a base class for all of the interceptors implements the logic around final status, metadata and cancellation. �_interceptors_task�_pending_add_done_callbacksN)�interceptors_taskr$ c C s || _ g | _| j �| j� d S �N)rM rN �add_done_callback�#_fire_or_add_pending_done_callbacks)r& rO r% r% r' �__init__8 s �zInterceptedCall.__init__c C s | � � d S rP )�cancel�r& r% r% r' �__del__? s zInterceptedCall.__del__c C s� | j s d S d}z|�� }|�� r$d}W n ttjfyB d}Y n0 |r^| j D ] }|| � qNn$| j D ] }t�| j|�}|� |� qdg | _ d S �NFT) rN �result�doner �asyncio�CancelledError� functools�partial�_wrap_add_done_callbackrQ )r& rO �call_completed�call�callbackr% r% r' rR B s$ � z3InterceptedCall._fire_or_add_pending_done_callbacks)ra � unused_callr$ c C s || � d S rP r% )r& ra rb r% r% r' r^ ] s z'InterceptedCall._wrap_add_done_callback�r$ c C sT | j �� s| j �� S z| j �� }W n( ty6 Y dS tjyJ Y dS 0 |�� S �NF)rM rY rT rX r rZ r[ �r& r` r% r% r' rT b s zInterceptedCall.cancelc C sn | j �� sdS z| j �� }W nH tyP } z |�� tjjkW Y d }~S d }~0 tj yd Y dS 0 |� � S rW ) rM rY rX r �coder- � StatusCode� CANCELLEDrZ r[ � cancelled�r& r` �errr% r% r' ri r s $zInterceptedCall.cancelledc C s@ | j �� sdS z| j �� }W n ttjfy6 Y dS 0 |�� S rW )rM rY rX r rZ r[ re r% r% r' rY s zInterceptedCall.done)ra r$ c C sz | j �� s| j�|� d S z| j �� }W n" ttjfyJ || � Y d S 0 |�� r^|| � nt� | j |�}|� |� d S rP ) rM rY rN �appendrX r rZ r[ r\ r] r^ rQ )r& ra r` r% r% r' rQ � s z!InterceptedCall.add_done_callbackc C s t � �d S rP ��NotImplementedErrorrU r% r% r' �time_remaining� s z InterceptedCall.time_remainingc � s` z| j I d H }W n@ ty< } z|�� W Y d }~S d }~0 tjyP Y d S 0 |�� I d H S rP )rM r �initial_metadatarZ r[ rj r% r% r' rp � s z InterceptedCall.initial_metadatac � s` z| j I d H }W n@ ty< } z|�� W Y d }~S d }~0 tjyP Y d S 0 |�� I d H S rP )rM r �trailing_metadatarZ r[ rj r% r% r' rq � s z!InterceptedCall.trailing_metadatac � sf z| j I d H }W nF ty< } z|�� W Y d }~S d }~0 tjyV tjj Y S 0 |�� I d H S rP )rM r rf rZ r[ r- rg rh rj r% r% r' rf � s zInterceptedCall.codec � sb z| j I d H }W nB ty< } z|�� W Y d }~S d }~0 tjyR t Y S 0 |�� I d H S rP )rM r �detailsrZ r[ �_LOCAL_CANCELLATION_DETAILSrj r% r% r' rr � s zInterceptedCall.detailsc � s` z| j I d H }W n@ ty< } z|�� W Y d }~S d }~0 tjyP Y dS 0 |�� I d H S �N� )rM r �debug_error_stringrZ r[ rj r% r% r' rv � s z"InterceptedCall.debug_error_stringc � s | j I d H }|�� I d H S rP )rM �wait_for_connectionre r% r% r' rw � s z#InterceptedCall.wait_for_connection)!r) r* r+ r, rZ �Taskr8 r r rS rV rR r �Callr^ r; rT ri rY rQ r r9 ro r rp rq r- rg rf r7 rr rv rw r% r% r% r' rL ! s, � � rL c @ s e Zd Zdd� ZdS )� _InterceptedUnaryResponseMixinc c s" | j �� E d H }|�� E d H }|S rP )rM � __await__�r& r` �responser% r% r' r{ � s z(_InterceptedUnaryResponseMixin.__await__N)r) r* r+ r{ r% r% r% r' rz � s rz c @ sb e Zd ZU eee ed< dd�dd�Zed�dd�Zee d�dd �Z e e ef d�d d �Z dS ) � _InterceptedStreamResponseMixin�_response_aiterNrc c C s d | _ d S rP )r rU r% r% r' �_init_stream_response_mixin� s z;_InterceptedStreamResponseMixin._init_stream_response_mixinc C s* | j I d H }|2 z3 d H W }|V q6 d S rP )rM r| r% r% r' �,_wait_for_interceptor_task_response_iterator� s zL_InterceptedStreamResponseMixin._wait_for_interceptor_task_response_iteratorc C s | j d u r| �� | _ | j S rP )r r� rU r% r% r' � __aiter__� s �z)_InterceptedStreamResponseMixin.__aiter__c � sF | j d u r| �� | _ z| j �d �I d H W S ty@ tj Y S 0 d S rP )r r� �asend�StopAsyncIterationr �EOFrU r% r% r' �read� s � z$_InterceptedStreamResponseMixin.read) r) r* r+ r r r r8 r� r� r� r r r� r% r% r% r' r~ � s � r~ c @ s� e Zd ZU eee ed< eej ed< eej ed< e � Z ee e d�dd�Z dd� Zeed �d d �Zed d �dd�Zd d�dd�Zd S )� _InterceptedStreamRequestMixin� _write_to_iterator_async_gen�_write_to_iterator_queue�_status_code_task)rG r$ c C s8 |d u r.t jdd�| _| �� | _d | _| j}nd | _|S )Nr )�maxsize)rZ �Queuer� �!_proxy_writes_as_request_iteratorr� r� )r& rG r% r% r' �_init_stream_request_mixin s �z9_InterceptedStreamRequestMixin._init_stream_request_mixinc C s4 | j I d H | j�� I d H }|tju r(q0|V q d S rP )rM r� �getr� �_FINISH_ITERATOR_SENTINEL)r& �valuer% r% r' r� s ��z@_InterceptedStreamRequestMixin._proxy_writes_as_request_iterator)r@ r` c � sL | j d u r | j�|�� �| _ tj| j�| j�|��| j ftjd�I d H d S )N)� return_when) r� �_loop� create_taskrf rZ �waitr� �put�FIRST_COMPLETED�r& r@ r` r% r% r' �&_write_to_iterator_queue_interruptible! s ���zE_InterceptedStreamRequestMixin._write_to_iterator_queue_interruptibleN�r@ r$ c � s� | j d u rt�t��z| jI d H }W n" tjtfyF t�t ��Y n0 |� � r\t�t ��n|j rlt�t ��| � ||�I d H |� � r�t�t ��d S rP )r� r � UsageErrorr rM rZ r[ r �InvalidStateErrorr rY �_done_writing_flagr r� r� r% r% r' �write4 s z$_InterceptedStreamRequestMixin.writerc c � s\ | j du rt�t��z| jI dH }W n tjyB t�t��Y n0 | � t j |�I dH dS )zUSignal peer that client is done writing. This method is idempotent. N) r� r r� r rM rZ r[ r� r r� r� r� re r% r% r' � done_writingJ s �z+_InterceptedStreamRequestMixin.done_writing)r) r* r+ r r r r8 rZ r� rx �objectr� r r� r� rL r� r� r� r% r% r% r' r� � s � � r� c s� e Zd ZU dZejed< ejed< e e e e e ee ej e e ejeeeejdd� � fdd� Ze e ee e e e e ej e e e eeed� d d �Ze e d �d d �Z� ZS )�InterceptedUnaryUnaryCallz�Used for running a `UnaryUnaryCall` wrapped by interceptors. For the `__await__` method is it is proxied to the intercepted call only when the interceptor task is finished. r� �_channelN� � interceptorsr@ r3 r4 r5 r6 �channelr2 �request_serializer�response_deserializer�loopr$ c s< | | _ || _| �| �|||||||| | � �} t� �| � d S rP )r� r� r� �_invoke�superrS � r& r� r@ r3 r4 r5 r6 r� r2 r� r� r� rO �� __class__r% r' rS l s �� z"InterceptedUnaryUnaryCall.__init__� r� r2 r3 r4 r5 r6 r@ r� r� r$ c � sJ t t tttjd�� ���fdd� � t|||||�} � t|�| |�I dH S )�(Run the RPC call wrapped in interceptors�r� r? r@ r$ c � sz | rJt �� | dd � �}| d �|||�I d H }t|tj�r@|S t|�S n,t|t|j�|j |j |j �j |j ���j� S d S �Nr r )r\ r] rB � isinstancer r �UnaryUnaryCallResponser r3 r4 r5 r6 r� r2 r� )r� r? r@ r" �call_or_response��_run_interceptorr� r� r& r% r' r� � s, �� �z;InterceptedUnaryUnaryCall._invoke.<locals>._run_interceptorN)r r= r1 r r r �list� r& r� r2 r3 r4 r5 r6 r@ r� r� r? r% r� r' r� � s � � �z!InterceptedUnaryUnaryCall._invokerc c C s t � �d S rP rm rU r% r% r' ro � s z(InterceptedUnaryUnaryCall.time_remaining)r) r* r+ r, rZ �AbstractEventLoopr8 r � AioChannelr r= r r r9 r r- r: r; �bytesr r rS r r� ro � __classcell__r% r% r� r' r� _ s8 �"� 5r� c s� e Zd ZU dZejed< ejed< e e j Z e e ee e ee ej e e ejeeeejdd� � fdd� Ze e ee e e e e ej e e eeee d� d d �Ze e d �d d �Z� ZS )�InterceptedUnaryStreamCallz=Used for running a `UnaryStreamCall` wrapped by interceptors.r� r� Nr� c sJ | | _ || _| �� d | _| �| �|||||||| | � �} t� �| � d S rP )r� r� r� �%_last_returned_call_from_interceptorsr� r� r� rS r� r� r% r' rS � s$ �� z#InterceptedUnaryStreamCall.__init__r� c � sJ t t tttjd�� ���fdd� � t|||||�} � t|�| |�I dH S )r� r� c � s� | rXt �� | dd � �}| d �|||�I d H }t|tj�rD|�_nt�j|��_�jS t|t|j �|j |j |j �j |j���j� �_�jS d S r� )r\ r] rD r� r r r� � UnaryStreamCallResponseIteratorr r3 r4 r5 r6 r� r2 r� )r� r? r@ r" �call_or_response_iteratorr� r% r' r� � sB ��� ����� z<InterceptedUnaryStreamCall._invoke.<locals>._run_interceptorN)r rC r1 r r r r� r� r% r� r' r� � s �. � �z"InterceptedUnaryStreamCall._invokerc c C s t � �d S rP rm rU r% r% r' ro 4 s z)InterceptedUnaryStreamCall.time_remaining) r) r* r+ r, rZ r� r8 r r� r r r r� r rC r r9 r r- r: r; r� r r rS r� ro r� r% r% r� r' r� � s: �$� Cr� c s� e Zd ZU dZejed< ejed< e e e e e e ee ej e e ejeeeejdd� � fdd� Ze e ee e e e e ej e e e eeed� d d �Ze e d �d d �Z� ZS )�InterceptedStreamUnaryCallz�Used for running a `StreamUnaryCall` wrapped by interceptors. For the `__await__` method is it is proxied to the intercepted call only when the interceptor task is finished. r� r� N� r� rG r3 r4 r5 r6 r� r2 r� r� r� r$ c sF | | _ || _| �|�}| �| �|||||||| | � �} t� �| � d S rP )r� r� r� r� r� r� rS � r& r� rG r3 r4 r5 r6 r� r2 r� r� r� rO r� r% r' rS H s" �� z#InterceptedStreamUnaryCall.__init__� r� r2 r3 r4 r5 r6 rG r� r� r$ c � sJ t t tttjd�� ���fdd� � t|||||�} � t|�| |�I dH S )r� �r� r? rG r$ c � s` | r0t �� | dd � �}| d �|||�I d H S t|t|j�|j|j|j�j |j ���j � S d S r� ) r\ r] rI r r r3 r4 r5 r6 r� r2 r� )r� r? rG r" r� r% r' r� w s& �� �z<InterceptedStreamUnaryCall._invoke.<locals>._run_interceptorN)r rE r1 r r r r� � r& r� r2 r3 r4 r5 r6 rG r� r� r? r% r� r' r� i s � � �z"InterceptedStreamUnaryCall._invokerc c C s t � �d S rP rm rU r% r% r' ro � s z)InterceptedStreamUnaryCall.time_remaining)r) r* r+ r, rZ r� r8 r r� r rE r r r9 r r- r: r; r� r r rS r r� ro r� r% r% r� r' r� 8 s8 �#� 0r� c s� e Zd ZU dZejed< ejed< e e j Z e e e e e e ee ej e e ejeeeejdd� � fdd� Ze e ee e e e e ej e e eeee d� d d �Ze e d �d d �Z� ZS )�InterceptedStreamStreamCallz>Used for running a `StreamStreamCall` wrapped by interceptors.r� r� Nr� c sT | | _ || _| �� | �|�}d | _| �| �|||||||| | � �} t� �| � d S rP ) r� r� r� r� r� r� r� r� rS r� r� r% r' rS � s& �� z$InterceptedStreamStreamCall.__init__r� c � sJ t t tttjd�� ���fdd� � t|||||�} � t|�| |�I dH S )r� r� c � s� | rXt �� | dd � �}| d �|||�I d H }t|tj�rD|�_nt�j|��_�jS t|t|j �|j |j |j �j |j���j� �_�jS d S r� )r\ r] rK r� r r r� � StreamStreamCallResponseIteratorr r3 r4 r5 r6 r� r2 r� )r� r? rG r" r� r� r% r' r� � sB ��� ����� z=InterceptedStreamStreamCall._invoke.<locals>._run_interceptorN)r rJ r1 r r r r� r� r% r� r' r� � s �- � �z#InterceptedStreamStreamCall._invokerc c C s t � �d S rP rm rU r% r% r' ro s z*InterceptedStreamStreamCall.time_remaining) r) r* r+ r, rZ r� r8 r r� r r r r� r rJ r r9 r r- r: r; r� r r rS r� ro r� r% r% r� r' r� � s> ��%� Br� c @ s� e Zd ZU dZeed< edd�dd�Zed�dd �Zed�d d �Z ed�d d �Z dd�dd�Z e e d�dd�Ze e d�dd�Ze e d�dd�Zejd�dd�Zed�dd�Ze e d�dd�Zd d � Zdd�d d �ZdS ) r� z4Final UnaryUnaryCall class finished with a response.� _responseN)r} r$ c C s || _ d S rP �r� )r& r} r% r% r' rS s z UnaryUnaryCallResponse.__init__rc c C s dS rd r% rU r% r% r' rT s z UnaryUnaryCallResponse.cancelc C s dS rd r% rU r% r% r' ri s z UnaryUnaryCallResponse.cancelledc C s dS )NTr% rU r% r% r' rY # s zUnaryUnaryCallResponse.donec C s t � �d S rP rm )r& �unused_callbackr% r% r' rQ & s z(UnaryUnaryCallResponse.add_done_callbackc C s t � �d S rP rm rU r% r% r' ro ) s z%UnaryUnaryCallResponse.time_remainingc � s d S rP r% rU r% r% r' rp , s z'UnaryUnaryCallResponse.initial_metadatac � s d S rP r% rU r% r% r' rq / s z(UnaryUnaryCallResponse.trailing_metadatac � s t jjS rP )r- rg �OKrU r% r% r' rf 2 s zUnaryUnaryCallResponse.codec � s dS rt r% rU r% r% r' rr 5 s z UnaryUnaryCallResponse.detailsc � s d S rP r% rU r% r% r' rv 8 s z)UnaryUnaryCallResponse.debug_error_stringc c s | j S rP r� rU r% r% r' r{ ; s z UnaryUnaryCallResponse.__await__c � s d S rP r% rU r% r% r' rw B s z*UnaryUnaryCallResponse.wait_for_connection)r) r* r+ r, r r8 rS r; rT ri rY rQ r r9 ro r rp rq r- rg rf r7 rr rv r{ rw r% r% r% r' r� s r� c @ s e Zd ZU eejejf ed< ee ed< eejejf ee dd�dd�Z e d�dd �Z e d�d d �Z e d�d d �Zdd�dd�Zee d�dd�Zee d�dd�Zee d�dd�Zejd�dd�Zed�dd�Zee d�dd�Zd d � Z dd�d d �Z dS ) �_StreamCallResponseIterator�_call�_response_iteratorN)r` �response_iteratorr$ c C s || _ || _d S rP )r� r� )r& r` r� r% r% r' rS J s z$_StreamCallResponseIterator.__init__rc c C s | j �� S rP )r� rT rU r% r% r' rT R s z"_StreamCallResponseIterator.cancelc C s | j �� S rP )r� ri rU r% r% r' ri U s z%_StreamCallResponseIterator.cancelledc C s | j �� S rP )r� rY rU r% r% r' rY X s z _StreamCallResponseIterator.donec C s | j �|� d S rP )r� rQ )r& ra r% r% r' rQ [ s z-_StreamCallResponseIterator.add_done_callbackc C s | j �� S rP )r� ro rU r% r% r' ro ^ s z*_StreamCallResponseIterator.time_remainingc � s | j �� I d H S rP )r� rp rU r% r% r' rp a s z,_StreamCallResponseIterator.initial_metadatac � s | j �� I d H S rP )r� rq rU r% r% r' rq d s z-_StreamCallResponseIterator.trailing_metadatac � s | j �� I d H S rP )r� rf rU r% r% r' rf g s z _StreamCallResponseIterator.codec � s | j �� I d H S rP )r� rr rU r% r% r' rr j s z#_StreamCallResponseIterator.detailsc � s | j �� I d H S rP )r� rv rU r% r% r' rv m s z._StreamCallResponseIterator.debug_error_stringc C s | j �� S rP )r� r� rU r% r% r' r� p s z%_StreamCallResponseIterator.__aiter__c � s | j �� I d H S rP )r� rw rU r% r% r' rw s s z/_StreamCallResponseIterator.wait_for_connection) r) r* r+ r r r r r8 r r rS r; rT ri rY rQ r r9 ro r rp rq r- rg rf r7 rr rv r� rw r% r% r% r' r� F s$ � r� c @ s& e Zd ZdZeeef d�dd�ZdS )r� zAUnaryStreamCall class wich uses an alternative response iterator.rc c � s t � �d S rP rm rU r% r% r' r� | s z$UnaryStreamCallResponseIterator.readN)r) r* r+ r, r r r r� r% r% r% r' r� w s r� c @ sV e Zd ZdZeeef d�dd�Zedd�dd�Z dd�d d �Z e e d�d d ��Z dS ) r� zBStreamStreamCall class wich uses an alternative response iterator.rc c � s t � �d S rP rm rU r% r% r' r� � s z%StreamStreamCallResponseIterator.readNr� c � s t � �d S rP rm )r& r@ r% r% r' r� � s z&StreamStreamCallResponseIterator.writec � s t � �d S rP rm rU r% r% r' r� � s z-StreamStreamCallResponseIterator.done_writingc C s | j jS rP )r� r� rU r% r% r' r� � s z3StreamStreamCallResponseIterator._done_writing_flag)r) r* r+ r, r r r r� r r� r� �propertyr; r� r% r% r% r' r� � s r� )@r, �abcr r rZ � collectionsr\ �typingr r r r r r r r r- � grpc._cythonr ru r r� r r r r r r r r � _metadatar �_typingr r r r r r r r �_utilsr rs r! � namedtupler1 r< r= rC rE rJ rL rz r~ r� r� r� r� r� r� r� r� r� r% r% r% r' �<module> s� ( % ��$(*. 5!b �f �s �e �x11 � �
cải xoăn