Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes14kdownloads
_call.cpython-313.pyc221 linesDownload Raw Back to __pycache__
1�

2��jwf����SrSSKrSSKrSSKJr SSKrSSKrSSKrSSKJ	r	J3r4JrJrJ
r
JrJr SSKrSSKJr SSKJr SSKJr SS	KJr SS5KJr SSKJr SSKJr SS
KJr SSKJr SSKJr SSKJr SSKJ r  SSKJ!r! Sr"Sr#Sr$Sr%Sr&Sr'Sr(Sr)\RT"\+5r,"SS\RZ5r.S\S\R^S\.4S jr0"S!S"5r1"S#S$\Rd5r3"S%S&\1\\ 5r4"S'S(\15r5"S)S*\15r6"S+S,\4\1\Rn5r7"S-S.\5\1\Rp5r8"S/S0\6\4\1\Rr5r9"S1S2\6\5\1\Rt5r:g)3z6Invocation-side implementation of gRPC Asyncio Python.�N)�partial)�Any�
AsyncIterator�	Generator�Generic�Optional�Tuple�Union)�_common)�cygrpc�)�6_base_call)�Metadata)�DeserializingFunction)�DoneCallbackType)�EOFType)�MetadataType)�
MetadatumType)�RequestIterableType)�RequestType)�ResponseType)�SerializingFunction)�AioRpcError�Call�UnaryStreamCall�UnaryUnaryCallz!Locally cancelled by application!z"Cancelled upon garbage collection!zRPC already finished.z0RPC is half closed after calling "done_writing".zBThe iterator and read/write APIs may not be mixed on a single RPC.z?<{} of RPC that terminated with:7	status = {}8	details = "{}"9>zZ<{} of RPC that terminated with:10	status = {}11	details = "{}"12	debug_error_string = "{}"13>c
�`^�\rSrSr%Sr\R\S'\\	\S'\\14\S'\\15\S'\\	\S'SS	\RS16\17S\18S\\	S
\\	SS4U4SjjjrS\R4SjrS\\	4Sjr
S\194SjrS\204SjrS\	4SjrS\	4SjrS\	4SjrS\	4SjrSrSrU=r$)r�Iz�An implementation of RpcError to be used by the asynchronous API.21 22Raised RpcError is a snapshot of the final status of the RPC, values are23determined. Hence, its methods no longer needs to be coroutines.24�_code�_details�_initial_metadata�_trailing_metadata�_debug_error_stringN�code�initial_metadata�trailing_metadata�details�debug_error_string�returnc�^>�[TU]5 XlX@lX lX0lXPlg)aVConstructor.25 26Args:27  code: The status code with which the RPC has been finalized.28  initial_metadata: Optional initial metadata that could be sent by the29    Server.30  trailing_metadata: Optional metadata that could be sent by the Server.31  details: Optional details explaining the reason of the error.32  debug_error_string: Optional string33N)�super�__init__rr r!r"r#)�selfr$r%r&r'r(�	__class__s      ��TD:\code\apps\devtools\python\user_packages\Python313\site-packages\grpc/aio/_call.pyr,�AioRpcError.__init__Vs,���$	�����34��
�!1��"3��#5� �c��UR$)z\Accesses the status code sent by the server.35 36Returns:37  The `grpc.StatusCode` status code.38)r�r-s r/r$�AioRpcError.codeos���z�z�r1c��UR$)zSAccesses the details sent by the server.39 40Returns:41  The description of the error.42)r r3s r/r'�AioRpcError.detailsws���}�}�r1c��UR$)z]Accesses the initial metadata sent by the server.43 44Returns:45  The initial metadata received.46)r!r3s r/r%�AioRpcError.initial_metadatas���%�%�%r1c��UR$)z_Accesses the trailing metadata sent by the server.47 48Returns:49  The trailing metadata received.50)r"r3s r/r&�AioRpcError.trailing_metadata�s���&�&�&r1c��UR$)zaAccesses the debug error string sent by the server.51 52Returns:53  The debug error string received.54)r#r3s r/r(�AioRpcError.debug_error_string�s���'�'�'r1c��[RURRURUR55UR5$)z-Assembles the error string for the RPC error.)�_NON_OK_CALL_REPRESENTATION�formatr.�__name__rr r#r3s r/�_repr�AioRpcError._repr�s9��*�1�1��N�N�#�#��J�J��M�M��$�$�	56�	57r1c�"�UR5$�N�rAr3s r/�__repr__�AioRpcError.__repr__�����z�z�|�r1c�"�UR5$rDrEr3s r/�__str__�AioRpcError.__str__�rHr1c��[U5URURURURUR5844$rD)�typerr!r"r r#r3s r/�59__reduce__�AioRpcError.__reduce__�sA����J��60�61��&�&��'�'��
�
��(�(�
�	62�		63r1)rr#r r!r")NN)r@�64__module__�__qualname__�__firstlineno__�__doc__�grpc�65StatusCode�__annotations__r�strrr,r$r'r%r&r(rArFrJrN�__static_attributes__�
__classcell__�r.s@r/rrIs�����?�?���s�m����)�)� ��*�*�!�#��&�"&�,0�
6��o�o�6�#�6�$�	6�66�#��6�%�S�M�
6�67�6�6�2�d�o�o����#���&�(�&�'�8�'�(�C�(�68�s�69��#�����7071�7273r1rr%�statusr)c���[[RUR5[R74"U5[R"UR55UR5UR5S9$)N)r'r()75rr�!CYGRPC_STATUS_CODE_TO_STATUS_CODEr$r�_create�76from_tupler&r'r()r%r[s  r/�_create_rpc_errorr`�sa����1�1�&�+�+�-�@����)�*����F�4�4�6�7���� �!�4�4�6��r1c���\rSrSr%Sr\R\S'\R\S'\77R\S'\\
S4\S'\\\S'\\\S	'S78\79RS\S\\S
\\S\RSS4SjrS%SjrS\4SjrS\S\4SjrS\4SjrS\4SjrS\SS4SjrS\\4SjrS\4SjrS\4SjrS\R4Sjr S\4Sjr!S\4Sjr"S%S jr#S\4S!jr$S\4S"jr%S\4S#jr&S$r'g)&r��zqBase implementation of client RPC Call object.80 81Implements logic around final status, metadata and cancellation.82�_loopr�_cython_call.�	_metadata�_request_serializer�_response_deserializer�cython_call�metadata�request_serializer�response_deserializer�loopr)Nc�T�XPlXl[U5UlX0lX@lgrD)rcrd�tuplererfrg)r-rhrirjrkrls      r/r,�
Call.__init__�s&���83�'���x����#5� �&;�#r1c��[US5(a6URR5(dUR[5 ggg)Nrd)�hasattrrd�done�_cancel�_GC_CANCELLATION_DETAILSr3s r/�__del__�Call.__del__�s9���4��(�(��1B�1B�1G�1G�1I�1I��L�L�1�2�2J�(r1c�6�URR5$rD)rd�	cancelledr3s r/rx�Call.cancelled�s��� � �*�*�,�,r1r'c�z�URR5(dURRU5 gg)z0Forwards the application cancellation reasoning.TF)rdrr�cancel)r-r's  r/rs�Call._cancel�s1��� � �%�%�'�'����$�$�W�-��r1c�,�UR[5$rD)rs�_LOCAL_CANCELLATION_DETAILSr3s r/r{�Call.cancel�s���|�|�7�8�8r1c�6�URR5$rD)rdrrr3s r/rr�	Call.done�s��� � �%�%�'�'r1�callbackc�P�[X5nURRU5 grD)rrd�add_done_callback)r-r��cbs   r/r��Call.add_done_callback�s ��
�X�
$�����+�+�B�/r1c�6�URR5$rD)rd�time_remainingr3s r/r��Call.time_remaining�s��� � �/�/�1�1r1c��~# �URR5IShv�Nn[R"U5$N7frD)rdr%rr_�r-�raw_metadata_tuples  r/r%�Call.initial_metadata�s5���#'�#4�#4�#E�#E�#G�G���"�"�#5�6�6�H�s�=�;�=c��# �URR5IShv�NR5nU(d84[5$[R"U5$N97frD)rdr[r&rr_r�s  r/r&�Call.trailing_metadata�sL����#�#�*�*�,�,�85�86�87�	�"��:���"�"�#5�6�6�	
-�s�A�A�:Ac��# �URR5IShv�NR5n[RU$N%7frD)rdr[r$rr])r-�cygrpc_codes  r/r$�	Call.codes;���!�.�.�5�5�7�7�=�=�?���8�8��E�E�8�s�A�A�&Ac��n# �URR5IShv�NR5$N7frD)rdr[r'r3s r/r'�Call.detailss)����'�'�.�.�0�0�9�9�;�;�0���5�3�5c��n# �URR5IShv�NR5$N7frD)rdr[r(r3s r/r(�Call.debug_error_string88s)����'�'�.�.�0�0�D�D�F�F�0�r�c��p# �URR5(a[R"5eUR	5IShv�NnU[89RR:waB[UR5IShv�NURR5IShv�N5egNeN,N
7frD)rd�is_locally_cancelled�asyncio�CancelledErrorr$rTrU�OKr`r%r[)r-r$s  r/�_raise_for_status�Call._raise_for_status
s�������1�1�3�3��(�(�*�*��Y�Y�[� ���4�?�?�%�%�%�#��+�+�-�-��'�'�.�.�0�0��
�&�!�.�0�s6�AB6�90B0�:B6�B2� B6�&B491�'92B6�2B6�4B6c�,�[UR5$rD)�reprrdr3s r/rA�93Call._reprs���D�%�%�&�&r1c�"�UR5$rDrEr3s r/rF�
Call.__repr__rHr1c�"�UR5$rDrEr3s r/rJ�Call.__str__rHr1)rdrcrerfrg�r)N)(r@rPrQrRrSr��AbstractEventLooprVrTrUr�_AioCallr	rrrrrr,ru�boolrxrWrsr{rrrr��floatr�r%r&r$r'r(r�rArFrJrX�r1r/rr�ss���94�$�$�$��?�?���/�/�!��]�C�'�(�(�!�"5�6�6�$�%:�;�;�<��_�_�<��<�%�%8�9�	<�95 (�(=�>�<��'�'�
<�96�<�3�97-�4�-��s��t��9��9�(�d�(�0�*:�0�t�0�2����2�7��7�7��7�F�D�O�O�F�<�s�<�G�#�G��'�s�'��#����r1rc� �\rSrSrSrSrSrSrg)�	_APIStylei!rr
�r�N)r@rPrQrR�UNKNOWN�ASYNC_GENERATOR�
READER_WRITERrXr�r1r/r�r�!s���G��O��Mr1r�c�^�\rSrSr%\R98\S'S\R994SjrS\4U4Sjjr	S\100\S\44Sjr
S	rU=r$)101�_UnaryResponseMixini'�_call_response�
response_taskc��XlgrD�r�)r-r�s  r/�_init_unary_response_mixin�._UnaryResponseMixin._init_unary_response_mixin*s��+�r1r)c�b>�[TU]5(aURR5 gg�NTF)r+r{r��r-r.s �r/r{�_UnaryResponseMixin.cancel-s(����7�>������&�&�(��r1Nc#�# �URShv�NnU[102RLahURR5(a[R"5e[URRURR5eU$N�![Ra' UR5(dUR	5 ef=f7f)z+Wait till the ongoing RPC request finishes.N)r�r�r�rxr{r�EOFrdr�r`r!�_status)r-�responses  r/�	__await__�_UnaryResponseMixin.__await__3s����		�"&�"5�"5�5�H��v�z�z�!�� � �5�5�7�7��,�,�.�.�'��%�%�7�7��%�%�-�-���103�O�16���%�%�	�104�>�>�#�#����
��	�s,�C�B�B�B�A=C�B�;C�Cr�)r@rPrQrRr��TaskrVr�r�r{rrrr�rXrYrZs@r/r�r�'sF����L�L� �,����,�����9�S�$��%<�=��r1r�c��^�\rSrSr%\\\S'\R\S'\	\S'S\R4Sjr105S\	4SjrS	\4U4S106jjr
S	\4SjrS	\\4SjrS	\4S
jrS	\\\44SjrSrU=r$)�_StreamResponseMixiniQ�_message_aiter�_preparation�_response_style�preparationc�H�SUlXl[RUlgrD)r�r�r�r�r�)r-r�s  r/�_init_stream_response_mixin�0_StreamResponseMixin._init_stream_response_mixinVs��"���'��(�0�0��r1�stylec��UR[RLaXlgURULa[R"[1075egrD)r�r�r�r�108UsageError�_API_STYLE_ERROR�r-r�s  r/�_update_response_style�+_StreamResponseMixin._update_response_style[sA�����9�#4�#4�4�#(� �
�
!�
!��
.��#�#�$4�5�5�/r1r)c�b>�[TU]5(aURR5 ggr�)r+r{r�r�s �r/r{�_StreamResponseMixin.cancelas(����7�>������$�$�&��r1c�# �UR5IShv�NnU[RLa2U7v� UR5IShv�NnU[RLaM2UR5IShv�N gNbN4N	7frD)�_readrr�r�)r-�messages  r/�_fetch_stream_responses�,_StreamResponseMixin._fetch_stream_responsesgsc����109�110��$���V�Z�Z�'��M� �J�J�L�(�G��V�Z�Z�'�111�$�$�&�&�&�
%�)�	'�s9�A?�A9�/A?�A;�A?� A?�3A=�4A?�;A?�=A?c��UR[R5 URcUR	5UlUR$rD)r�r�r�r�r�r3s r/�	__aiter__�_StreamResponseMixin.__aiter__ps?���#�#�I�$=�$=�>����&�"&�">�">�"@�D���"�"�"r1c��# �URIShv�N URR5IShv�NnU[RLa[R$[R"XR5$NjNI![Ra' UR5(dUR
5 ef=f7frD)r�rd�receive_serialized_messager�r�rxr{rr�r�deserializerg)r-�raw_responses  r/r��_StreamResponseMixin._readvs���������	�!%�!2�!2�!M�!M�!O�O�L��6�:�:�%��:�:���"�"�<�1L�1L�M�M�	 �P���%�%�	��>�>�#�#����
��	�s6�B?�A=�B?�B�A?�B�AB?�?B�;B<�<B?c��X# �UR5(a(UR5IShv�N [R$UR	[112R5 UR5IShv�NnU[RLaUR5IShv�N U$NxN3N1137frD)rrr�rr�r�r�r�r�)r-�response_messages  r/�read�_StreamResponseMixin.read�s�����9�9�;�;��(�(�*�*�*��:�:���#�#�I�$;�$;�<�!%����-���v�z�z�)��(�(�*�*�*���
+�.�
+�s4�)B*�B$�AB*�2B&�3*B*�B(�B*�&B*�(B*)r�r�r�)r@rPrQrRrrrVr�r�r�r�r�r�r{r�r�r�r114rr�rXrYrZs@r/r�r�Qs����!�,�/�/��,�,����1�w�|�|�1�1156�I�6����'�|�'�#�=��6�#�N�\�N�  �E�'�<�"7�8� � r1r�c�^�\rSrSr%\R116\S'\\S'\\R\S'\117\S'S\\4SjrS\1184S	jr
S119\4U4SjjrSrS\S120S
4SjrS\S121S
4SjrSSjrS\S122S
4SjrSSjrSSjrSrU=r$)�_StreamRequestMixini��_metadata_sent�_done_writing_flag�_async_request_poller�_request_style�request_iteratorc��[R"5UlSUlUbEURRUR
U55Ul[RUl123gSUl[RUl124g)NF)r��Eventr�r�rc�create_task�_consume_request_iteratorr�r�r�r�r�)r-r�s  r/�_init_stream_request_mixin�._StreamRequestMixin._init_stream_request_mixin�sn��&�m�m�o���"'����'�)-���)?�)?��.�.�/?�@�*�D�&�#,�";�";�D��)-�D�&�"+�"9�"9�D�r1r�c�V�URULa[R"[5egrD)r�rr�r�r�s  r/�_raise_for_different_style�._StreamRequestMixin._raise_for_different_style�s'�����e�+��#�#�$4�5�5�,r1r)c�|>�[TU]5(a(URbURR5 ggr�)r+r{r�r�s �r/r{�_StreamRequestMixin.cancel�s4����7�>����)�)�5��*�*�1�1�3��r1c�8�URR5 grD)r��setr3s r/�_metadata_sent_observer�+_StreamRequestMixin._metadata_sent_observer�s�������!r1Nc��v# �[R"U5(d[US5(a'UShv�NnURU5IShv�N M%UHnURU5IShv�N M UR5IShv�N gN\ND![a!n[125R
SU5 SnA gSnAff=f126NMNU![a!n[127R
SU5 SnA gSnAff=fNi! [128R
S[R"55 UR5 g=f7f)Nr�z2Exception while consuming the request_iterator: %sz,Client request_iterator raised exception:129%s)�inspect�130isasyncgenrq�_writer�_LOGGER�debug�
_done_writing�	traceback�131format_excr{)r-r��request�	rpc_errors    r/r��-_StreamRequestMixin._consume_request_iterator�s"���'	��!�!�"2�3�3�w� �+�8�8�&6��'�132�"�k�k�'�2�2�2� 0�G�133�"�k�k�'�2�2�2� 0��$�$�&�&�&�5�2��&���
�
�!8�&������&6�3��&���
�
�!8�&������
'��	�
�M�M�?��$�$�&�
�
�K�K�M�s��D9�.C9�C�B�C�C9�B�B�B�C9�C	�1C�2C	�6C9�
C7�C9�D9�C�B�134C�!B=�7C9�<D9�=C�C9�C	�	135C4�C/�)C9�.D9�/C4�4C9�9;D6�4D9rc��^# �UR5(a[R"[5eUR(a[R"[1365eURR5(dOURR5IShv�N UR5(aUR5IShv�N [R"XR5nURRU5IShv�N gNvNKN	![R aGnURR#[%U55 UR5IShv�N SnAgSnAf[R&a' UR)5(dUR+5 ef=f7frD)rrr��InvalidStateError�_RPC_ALREADY_FINISHED_DETAILSr��_RPC_HALF_CLOSED_DETAILSr��is_set�waitr�r�	serializerfrd�send_serialized_messager�
InternalError�set_internal_errorrWr�rxr{)r-r�serialized_request�errs    r/r�_StreamRequestMixin._write�s5����9�9�;�;��+�+�,I�J�J��"�"��+�+�,D�E�E��"�"�)�)�+�+��%�%�*�*�,�,�,��y�y�{�{��,�,�.�.�.�$�.�.��-�-�137��	��#�#�;�;�<N�O�O�O�
-�.�
P���#�#�	+����0�0��S��:��(�(�*�*�*���%�%�	��>�>�#�#����
��	�sl�BF-�D�,F-�D�$F-�,D�138D�D�F-�F-�D�F*�*7E,�!E$�"E,�'F-�,>F*�*F-c��0# �UR5(agUR(d+SUlURR5IShv�N ggN![R139a' UR
5(dUR5 ef=f7f)NT)rrr�rd�send_receive_closer�r�rxr{r3s r/r�!_StreamRequestMixin._done_writing�sx����9�9�;�;���&�&�&*�D�#�
��'�'�:�:�<�<�<�	'�=���)�)�
��~�~�'�'��K�K�M��
�s.�/B�A�A�A�B�A�;B�Bc��# �UR[R5 URU5IShv�N gN7frD)r�r�r�r)r-rs  r/�write�_StreamRequestMixin.write	s+����'�'�	�(?�(?�@��k�k�'�"�"�"�s�4>�<�>c��~# �UR[R5 UR5IShv�N gN7f)zESignal peer that client is done writing.140 141This method is idempotent.142N)r�r�r�rr3s r/�done_writing� _StreamRequestMixin.done_writing
s-���143	
�'�'�	�(?�(?�@�� � �"�"�"�s�3=�;�=c��# �URR5IShv�N UR5(aUR5IShv�N ggN3N7frD)r�rrrr�r3s r/�wait_for_connection�'_StreamRequestMixin.wait_for_connectionsG����!�!�&�&�(�(�(��9�9�;�;��(�(�*�*�*��	)�*�s!�A�A�,A�
A�A�A)r�r�r�r�r�)r@rPrQrRr�r�rVr�rr�r�rr�r�r{r�r�rrrrrr!rXrYrZs@r/r�r��s�����M�M�!���#�G�L�L�1�1���:� (�)<� =�:� 6�	�6����"�*� 3�*�	
�*�X�K��D��.�#�;�#�4�#�#�+�+r1r�c��^�\rSrSr%Sr\\S'\R\S'S\S\	\144S\S\	\RS	\	\S145\R S\S\	\S
\	\S\R(SS4U4SjjrS\4SjrSSjrSrU=r$)rizuObject for managing unary-unary RPC calls.146 147Returned when an instance of `UnaryUnaryMultiCallable` object is called.148�_request�_invocation_taskr�deadlineri�credentials�wait_for_ready�channel�methodrjrkrlr)Nc�149>�[TU]URXrXE5UUU	U1505 Xl[R151"5UlU152RUR55Ul	URUR5 grD)r+r,�callr$r�build_census_context�_contextr��_invoker%r��r-rr&rir'r(r)r*rjrkrlr.s           �r/r,�UnaryUnaryCall.__init__%sp���	����L�L��;�G���!��	153� �
��3�3�5��
� $� 0� 0����� @����'�'��(=�(=�>r1c���# �[R"URUR5nURRXRUR5IShv�NnURR5(a![R"WUR5$[R $NT![Ra( UR5(dUR5 N�f=f7frD)rrr$rfrd�unary_unaryrer.r�r�rxr{�is_okr�rgrr�)r-r�serialized_responses   r/r/�UnaryUnaryCall._invoke>s����$�.�.��M�M�4�3�3�154��	�(,�(9�(9�(E�(E�"�N�N�D�M�M�)�#�����"�"�$�$��&�&�#�T�%@�%@��
��z�z��#���%�%�	��>�>�#�#����
��	�s;�,C8�3B9�"B7�#B9�'AC8�7B9�99C5�2C8�4C5�5C8c��# �URIShv�N UR5(aUR5IShv�N ggN3N7frD)r%rrr�r3s r/r!�"UnaryUnaryCall.wait_for_connectionTs>����#�#�#�#��9�9�;�;��(�(�*�*�*��	$�*�� �A155�A�,A156�A�A157�A158)r.r%r$r�)r@rPrQrRrSrrVr�r�rr�rrT�CallCredentialsr�r�159AioChannel�bytesrrr�r,rr/r!rXrYrZs@r/rrs�����160���l�l�"�?��?��5�/�?��	?�161�d�2�2�3�?�!���
?��"�"�?��?�%�%8�9�?� (�(=�>�?��'�'�?�162�?�2�|��,+�+r1rc��^�\rSrSr%Sr\\S'\R\S'S\S\	\163S\S\	\RS	\	\S164\R S\S\	\S
\	\S\R(SS4U4SjjrS\4SjrSSjrSrU=r$)riZzwObject for managing unary-stream RPC calls.165 166Returned when an instance of `UnaryStreamMultiCallable` object is called.167r$�_send_unary_request_taskrr&rir'r(r)r*rjrkrlr)Nc�168>�[TU]URXrXE5UUU	U1695 Xl[R170"5UlU171RUR55Ul	URUR5 grD)r+r,r,r$rr-r.r��_send_unary_requestr>r�r0s           �r/r,�UnaryStreamCall.__init__dsx���	����L�L��;�G���!��	172� �
��3�3�5��
�(,�(8�(8��$�$�&�)173��%�	
�(�(��)F�)F�Gr1c��T# �[R"URUR5nURRXRUR5IShv�N gN![Ra' UR5(dUR5 ef=f7frD)rrr$rfrd�initiate_unary_streamrer.r�r�rxr{)r-rs  r/r@�#UnaryStreamCall._send_unary_requests����$�.�.��M�M�4�3�3�174��	��#�#�9�9�"�N�N�D�M�M��
�
���%�%�	��>�>�#�#����
��	�s.�,B(�3A*�"A(�#A*�'B(�(A*�*;B%�%B(c��# �URIShv�N UR5(aUR5IShv�N ggN3N7frD)r>rrr�r3s r/r!�#UnaryStreamCall.wait_for_connection�s>����+�+�+�+��9�9�;�;��(�(�*�*�*��	,�*�r9)r.r$r>r�)r@rPrQrRrSrrVr�r�rr�rrTr:r�rr;r<rrr�r,rr@r!rXrYrZs@r/rrZs�����175��%�l�l�*�H��H��5�/�H��	H�176�d�2�2�3�H�!���
H��"�"�H��H�%�%8�9�H� (�(=�>�H��'�'�H�177�H�6�<��+�+r1rc��^�\rSrSrSrS\\S\\S\S\\	RS\\S\RS	\S178\\S\\S\R$S
S4U4SjjrS
\4SjrSrU=r$)�StreamUnaryCalli�zwObject for managing stream-unary RPC calls.179 180Returned when an instance of `StreamUnaryMultiCallable` object is called.181r�r&rir'r(r)r*rjrkrlr)Nc��>�[TU]URXrXE5UUU	U1825 [R"5UlUR
U5 URU183RUR555 grD)184r+r,r,rr-r.r�r�r��_conduct_rpc�r-r�r&rir'r(r)r*rjrkrlr.s           �r/r,�StreamUnaryCall.__init__�so���	����L�L��;�G���!��	185��3�3�5��
��'�'�(8�9��'�'��(8�(8��9J�9J�9L�(M�Nr1c��# �URRURURUR5IShv�NnURR5(a [R"XR5$[R$NS![186Ra' UR5(dUR5 ef=f7frD)rd�stream_unaryrer�r.r�r�rxr{r4rr�rgrr�)r-r5s  r/rJ�StreamUnaryCall._conduct_rpc�s����	�(,�(9�(9�(F�(F����� <� <�d�m�m�)�#�����"�"�$�$��&�&�#�%@�%@��
��z�z��#���%�%�	��>�>�#�#����
��	�s/�C�>B�B�B�AC�B�;C�C)r.)r@rPrQrRrSrrr�rrTr:r�rr;r<rrr�r�r,rrJrXrYrZs@r/rHrH�s�����O�"�#6�7�O��5�/�O��	O�187�d�2�2�3�O�!���
O��"�"�O��O�%�%8�9�O� (�(=�>�O��'�'�O�188�O�2�L��r1rHc��^�\rSrSr%Sr\R\S'S\\	S\\189S\S\\RS\\S	\R S190\S\\S\\S
\R(SS4U4SjjrSrSrU=r$)�StreamStreamCalli�zyObject for managing stream-stream RPC calls.191 192Returned when an instance of `StreamStreamMultiCallable` object is called.193�_initializerr�r&rir'r(r)r*rjrkrlr)Nc�4>�[TU]URXrXE5UUU	U1945 [R"5UlURRUR55Ul	URU5 URUR5 grD)r+r,r,rr-r.rcr��_prepare_rpcrRr�r�rKs           �r/r,�StreamStreamCall.__init__�s����	����L�L��;�G���!��	195��3�3�5��
� �J�J�2�2�4�3D�3D�3F�G����'�'�(8�9��(�(��):�):�;r1c��# �URRURURUR5IShv�N gN![196Ra* UR5(dUR5 ggf=f7f)z�Prepares the RPC for receiving/sending messages.197 198All other operations around the stream should only happen after the199completion of this method.200N)	rd�initiate_stream_streamrer�r.r�r�rxr{r3s r/rT�StreamStreamCall._prepare_rpc�sn���	��#�#�:�:����� <� <�d�m�m��
�
���%�%�	��>�>�#�#����
�$�	�s:�B�>A201�A�A202�B�A203�2049B�B�B�B)r.rR)r@rPrQrRrSr�r�rVrrr�rrTr:r�rr;r<rrr�r,rTrXrYrZs@r/rQrQ�s�����205�,�,��<�"�#6�7�<��5�/�<��	<�206�d�2�2�3�<�!���
<��"�"�<��<�%�%8�9�<� (�(=�>�<��'�'�<�207�<�2�r1rQ);rSr��enum�	functoolsrr��loggingr�typingrrrrrr	r208rTr�grpc._cythonr�rrer�_typingrrrrrrrrr�__all__r~rtrr
r��_OK_CALL_REPRESENTATIONr>�	getLoggerr@r�RpcErrorr�AioRpcStatusr`r�IntEnumr�r�r�r�rrrHrQr�r1r/�<module>rfs���=���������������*�%��!�"�(� �!�(�209D��A��?�� 7��M��H��210K��211���212�213�H�214%��g215�$�-�-�g216�T217�"�218����219��220�^�^�B�����'�$��� 5�'�T@ �4�@ �FD+�$�D+�N<+�(�$�221�0I�0I�<+�~5+�*�D�*�2L�2L�5+�r0��,�d�J�4N�4N�0�f0��-�t�Z�5P�5P�0r1
codekingpro/portable-devtools · Team Ai