Team Ai
Datasetpublic

codekingpro/portable-devtools

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

2��j�X�
��SrSSKrSSKrSSKJrJrJrJrJr SSK	r	SSK	J3r4 SSK	Jr SSK	Jr SSK
Jr SS	KJr SS5KJr SSKJr SSKJr SS
KJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r  SSK!J"r" SSK#J$r$ SSK#J%r% SSK#J&r& SSK#J'r' SSK#J(r( SSK#J)r) SSK#J*r* SS K+J,r, S!R[\R\5r/\R`SS":aS#\\Rb4S$jr2OS#\\Rb4S%jr2S&\$S'\\	Rf4S(jr4"S)S*5r5"S+S,\5\Rl5r6"S-S.\5\Rn5r7"S/S0\5\Rp5r8"S1S2\5\Rr5r9"S3S4\Rt5r:S;S5\;S6\\$S'\\	RfS7\\\4S8jjr<S;S5\;S9\	RzS6\\$S'\\	RfS7\\\46S:jjr>g)<z6Invocation-side implementation of gRPC Asyncio Python.�N)�Any�Iterable�List�Optional�Sequence)�_common)�_compression)�_grpcio_metadata)�cygrpc�)�7_base_call)�
_base_channel)�StreamStreamCall)�StreamUnaryCall)�UnaryStreamCall)�UnaryUnaryCall)�ClientInterceptor)�InterceptedStreamStreamCall)�InterceptedStreamUnaryCall)�InterceptedUnaryStreamCall)�InterceptedUnaryUnaryCall)�StreamStreamClientInterceptor)�StreamUnaryClientInterceptor)�UnaryStreamClientInterceptor)�UnaryUnaryClientInterceptor)�Metadata)�ChannelArgumentType)�DeserializingFunction)�MetadataType)�RequestIterableType)�RequestType)�ResponseType)�SerializingFunction)�_timeout_to_deadlinezgrpc-python-asyncio/{}��returnc�>�[RR5$�N)�asyncio�Task�	all_tasks���WD:\code\apps\devtools\python\user_packages\Python313\site-packages\grpc/aio/_channel.py�8_all_tasksr/7s���|�|�%�%�'�'r-c�,�[R"5$r()r)r+r,r-r.r/r/<s��� � �"�"r-�base_options�compressionc��[R"U5n[RR[944n[
U5U-U-$r()r	�create_channel_optionr�
ChannelArgKey�primary_user_agent_string�_USER_AGENT�tuple)r1r2�compression_channel_argument�user_agent_channel_arguments    r.�_augment_channel_argumentsr;@sX��$0�#E�#E��$� �10
� � �:�:��	11�#��	�l��12&�	'�13%�	&�r-c�|�\rSrSr%Sr\R\S'\R\S'\14\S'\\\S'\\
\S'\\\\S'\\\S	'\R\S'S15\RS\16S\\S
\\
S\\\S\\S\RSS4Sjr\SS\\S\\R,S\4Sjj5rSrg)�_BaseMultiCallable�SzjBase class of all multi callable objects.17 18Handles the initialization logic and stores common attributes.19�_loop�_channel�_method�_request_serializer�_response_deserializer�
_interceptors�_references�channel�method�request_serializer�response_deserializer�interceptors�20references�loopr&Nc�X�XplXlX lX0lX@lXPlX`lgr()r?r@rArBrCrDrE)�selfrFrGrHrIrJrKrLs        r.�__init__�_BaseMultiCallable.__init__cs+���21��
���#5� �&;�#�)��%�r-�metadatar2c��U=(d22 [5n[U[5(d4[U[5(a[R"[	U55nU(a[[23R"X56nU$)z�Based on the provided values for <metadata> or <compression> initialise the final24metadata, as it should be used for the current call.25)r�26isinstancer�27from_tupler8r	�augment_metadata)rQr2s  r.�_init_metadata�!_BaseMultiCallable._init_metadatausf���)�x�z���(�H�-�-�*��h�328�329� �*�*�5��?�;�H����.�.�x�E��H��r-)r@rDr?rArErBrC)NN)�__name__�30__module__�__qualname__�__firstlineno__�__doc__r)�AbstractEventLoop�__annotations__r�31AioChannel�bytesrr#rrrrrrO�staticmethodr�grpc�CompressionrrV�__static_attributes__r,r-r.r=r=Ss#���32�$�$�$�����
�N�!�"5�6�6�$�%:�;�;��H�%6�7�8�8��c����$�$�$�&��"�"�&��&�%�%8�9�	&�33 (�(=�>�&��x�(9�:�;�
&���I�&��'�'�&�34�&�$�+/�26���<�(���d�.�.�/��35���r-r=c��\rSrSrSSSSSS.S\S\\S\\S\\RS\\36S	\\RS37\R\\44SjjrSrg)
�UnaryUnaryMultiCallable�N��timeoutrQ�credentials�wait_for_readyr2�requestrirQrjrkr2r&c
��URX65nUR(dQ[U[U5UUUURUR38URURUR539nU$[URUUUUUURUR40URURUR5nU$r()41rVrDrr$r@rArBrCr?r�rNrlrirQrjrkr2�calls        r.�__call__� UnaryUnaryMultiCallable.__call__�s����&�&�x�=���!�!�!��$�W�-�����
�
�����(�(��+�+��42�43��D�6��-��"�"�������
�
�����(�(��+�+��44�45��D��r-r,)rXrYrZr[r!r�floatrrb�CallCredentials�boolrcr
rr"rprdr,r-r.rfrf�s���$(�+/�6:�)-�26�'��'��%��	'�46�<�(�'��d�2�2�3�
'�!���'��d�.�.�/�'�47�	"�	"�;��#<�	=�'�'r-rfc��\rSrSrSSSSSS.S\S\\S\\S\\RS\\48S	\\RS49\R\\44SjjrSrg)
�UnaryStreamMultiCallable�NrhrlrirQrjrkr2r&c
��URX65nUR(dQ[U[U5UUUURUR50URURUR551nU$[URUUUUUURUR52URURUR5nU$r()53rVrDrr$r@rArBrCr?rrns        r.rp�!UnaryStreamMultiCallable.__call__�s����&�&�x�=���!�!�"��$�W�-�����
�
�����(�(��+�+��54�55��D�6��.��"�"�������
�
�����(�(��+�+��56�57��D��r-r,)rXrYrZr[r!rrrrrbrsrtrcr
rr"rprdr,r-r.rvrv�s���$(�+/�6:�)-�26�(��(��%��	(�58�<�(�(��d�2�2�3�
(�!���(��d�.�.�/�(�59�	#�	#�K��$=�	>�(�(r-rvc��\rSrSrSS\\S\\S\\S\\RS\\60S\\RS	\R4S61jjrSrg)
�StreamUnaryMultiCallable��N�request_iteratorrirQrjrkr2r&c
��URX65nUR(dQ[U[U5UUUURUR62URURUR563nU$[URUUUUUURUR64URURUR5nU$r()65rVrDrr$r@rArBrCr?r�rNr}rirQrjrkr2ros        r.rp�!StreamUnaryMultiCallable.__call__�s����&�&�x�=���!�!�"� �$�W�-�����
�
�����(�(��+�+��66�67��D�6��.��"�"� ������
�
�����(�(��+�+��68�69��D��r-r,�NNNNNN)rXrYrZr[rr rrrrbrsrtrcr
rrprdr,r-r.r{r{�s���70;?�#'�+/�6:�)-�26�'�"�#6�7�'��%��'��<�(�	'�71�d�2�2�3�'�!���
'��d�.�.�/�'�72�	#�	#�'�'r-r{c��\rSrSrSS\\S\\S\\S\\RS\\73S\\RS	\R4S74jjrSrg)
�StreamStreamMultiCallableiNr}rirQrjrkr2r&c
��URX65nUR(dQ[U[U5UUUURUR75URURUR576nU$[URUUUUUURUR77URURUR5nU$r()78rVrDrr$r@rArBrCr?rrs        r.rp�"StreamStreamMultiCallable.__call__s����&�&�x�=���!�!�#� �$�W�-�����
�
�����(�(��+�+��79�80��D�6��/��"�"� ������
�
�����(�(��+�+��81�82��D��r-r,r�)rXrYrZr[rr rrrrbrsrtrcr
rrprdr,r-r.r�r�s���83;?�#'�+/�6:�)-�26�'�"�#6�7�'��%��'��<�(�	'�84�d�2�2�3�'�!���
'��d�.�.�/�'�85�	$�	$�'�'r-r�c�v�\rSrSr%\R86\S'\R\S'\	\87\S'\	\\S'\	\\S'\	\
\S'S\S	\S88\\R"S\\R&S\\\489S
jrSrSrSrS%S\\4SjjrSrS&S\S\R<4SjjrS\R<SS4Sjr S'Sjr!S\S\"4Sjr#S(S\S\\$S\\%S\\S\&490S jjr'S(S\S\\$S\\%S\\S\(491S!jjr)S(S\S\\$S\\%S\\S\*492S"jjr+S(S\S\\$S\\%S\\S\,493S#jjr-S$r.g))�Channeli>r?r@�_unary_unary_interceptors�_unary_stream_interceptors�_stream_unary_interceptors�_stream_stream_interceptors�target�optionsrjr2rJc���/Ul/Ul/Ul/UlUGbjUGHcn[	U[945(aURR
U5 M6[	U[5(aURR
U5 Mh[	U[5(aURR
U5 M�[	U[5(aURR
U5 M�[SRU5SR[95R5-SR[R5-SR[R5-SR[R5-5e [R"5Ul[R "["R$"U5['X$5UUR5Ulg)a�Constructor.96 97Args:98  target: The target to which to connect.99  options: Configuration options for the channel.100  credentials: A cygrpc.ChannelCredentials or None.101  compression: An optional value indicating the compression method to be102    used over the lifetime of the channel.103  interceptors: An optional list of interceptors that would be used for104    intercepting any RPC executed with that channel.105NzInterceptor {} must be z{} or z{}. )r�r�r�r�rSr�appendrrr�106ValueError�formatrXr�get_working_loopr?r_r�encoder;r@)rNr�r�rjr2rJ�interceptors       r.rO�Channel.__init__Fs���&*,��&�*,��'�*,��'�+-��(��#�+���k�+F�G�G��2�2�9�9�+�F���-I�J�J��3�3�:�:�;�G���-I�J�J��3�3�:�:�;�G���-J�K�K��4�4�;�;�K�H�$�1�8�8��E�"�/�/�*E�*N�*N�O�P�"�/�/�*F�*O�*O�P�Q�#�/�/�*F�*O�*O�P�Q�!�-�-�(E�(N�(N�O�	P��� ,�$�,�,�.��107��)�)��N�N�6�"�&�w�<���J�J�	108��
r-c��# �U$7fr(r,�rNs r.�109__aenter__�Channel.__aenter__ys110�����s�c��B# �URS5IShv�N gN7fr(��_close)rN�exc_type�exc_val�exc_tbs    r.�	__aexit__�Channel.__aexit__|s����k�k�$��������c���# �URR5(agURR5 [5n/n/nUGHnUR	SS9nU(dMUSnURRS5n	U	cMB[U	[R5(dMc[U	S5(aU	RURLaM�OR[U	S5(a&U	RRURLaM�OSU	3n111[R"U1125eUR!U	5 UR!U5 GM U(a#U(a["R$"XAS	9IShv�N UHnUR'5 M URR)5 g![113anS[
U5;aSnAGM�eSnAff=fNa7f)114Nr)�limit�framerrNr@�_cython_callzUnrecognized call object: )ri)r@�closed�closingr/�	get_stack�AttributeError�str�f_locals�getrSr
�Call�hasattrr�r�
InternalErrorr�r)�wait�cancel�close)rN�grace�tasks�calls�115call_tasks�task�stack�attribute_errorr��	candidate�	error_msgros            r.r��Channel._closes�����=�=���!�!��	
�
�
����������116��D�
����Q��/��*���!�H�E����*�*�6�2�I��$��I�z���)O�)O��9�j�1�1� �)�)����>� �?��Y��7�7� �-�-�6�6�d�m�m�K� �L�#=�Y�K� H�I� �.�.�y�9�9����Y�'��!�!�$�'�_�f�Z��,�,�z�9�9�9��D��K�K�M��	
�
�
�����q"�
��c�/�2�2����#
��b
:�sO�AG�F4�!*G�G�0CG�;G�<8G�4117G�>G�
G�G�G�GNr�c��B# �URU5IShv�N gN7fr(r�)rNr�s  r.r��
Channel.close�s����k�k�%� � � �r�c��[US5(a;URR5(dURR5 ggg)Nr@)r�r@r�r�r�s r.�__del__�Channel.__del__�s:���4��$�$�T�]�]�-A�-A�-C�-C��M�M���!�.D�$r-�try_to_connectr&c�^�URRU5n[RU$r()r@�check_connectivity_stater�1CYGRPC_CONNECTIVITY_STATE_TO_CHANNEL_CONNECTIVITY)rNr��results   r.�	get_state�Channel.get_state�s)�����7�7��G���H�H��P�Pr-�last_observed_statec��# �URRURSS5IShv�N(degN7f)Nr)r@�watch_connectivity_state�value)rNr�s  r.�wait_for_state_change�Channel.wait_for_state_change�s=����]�]�;�;��%�%�a�(�$�118�119�120�	121�122�s�->�<�
>c���# �URSS9nU[RR:waIUR	U5IShv�N URSS9nU[RR:waMHggN57f)NT)r�)r�rb�ChannelConnectivity�READYr�)rN�states  r.�
channel_ready�Channel.channel_ready�sf������d��3���t�/�/�5�5�5��,�,�U�3�3�3��N�N�$�N�7�E��t�/�/�5�5�5�3�s�AA<�A:�1A<�8A<rGc��gr(r,)rNrGs  r.�_get_registered_call_handle�#Channel._get_registered_call_handle�s��r-rHrI�_registered_methodc	��[UR[R"U5UUURU/UR1235$r()rfr@rr�r�r?�rNrGrHrIr�s     r.�unary_unary�Channel.unary_unary�s?��'��M�M��N�N�6�"��!��*�*�
�F��J�J�124�	125r-c	��[UR[R"U5UUURU/UR1265$r()rvr@rr�r�r?r�s     r.�unary_stream�Channel.unary_stream��?��(��M�M��N�N�6�"��!��+�+�
�F��J�J�127�	128r-c	��[UR[R"U5UUURU/UR1295$r()r{r@rr�r�r?r�s     r.�stream_unary�Channel.stream_unaryr�r-c	��[UR[R"U5UUURU/UR1305$r()r�r@rr�r�r?r�s     r.�
stream_stream�Channel.stream_stream&s?��)��M�M��N�N�6�"��!��,�,�
�F��J�J�131�	132r-)r@r?r�r�r�r�r()F)r&N)NNF)/rXrYrZr[r)r]r^rr_rrrrrr�rr�ChannelCredentialsrbrcrrrOr�r�r�rrr�r�rtr�r�r�r��intr�r#rrfr�rvr�r{r�r�r�rdr,r-r.r�r�>sh���$�$�$�����#�$?�@�@� $�%A� B�B� $�%A� B�B�!%�&C�!D�D�1133��1134�%�1135��f�7�7�8�	1136�137�d�.�.�/�1138��x�(9�:�;�
1139�f� �F�P!��%��!�"�140&+�Q�"�Q�	
�	!�	!�Q�141�!�5�5�142�143�144�8�
�#�
�#�
�=A�AE�-2�145��146�%�%8�9�147� (�(=�>�	148�149%�T�N�150�151!�
152�.=A�AE�-2�153��154�%�%8�9�155� (�(=�>�	156�157%�T�N�158�159"�
160�.=A�AE�-2�161��162�%�%8�9�163� (�(=�>�	164�165%�T�N�166�167"�
168�.=A�AE�-2�169��170�%�%8�9�171� (�(=�>�	172�173%�T�N�174�175#�
176�177r-r�r�r�rJc�*�[UUcSOUSUU5$)a�Creates an insecure asynchronous Channel to a server.178 179Args:180  target: The server address181  options: An optional list of key-value pairs (:term:`channel_arguments`182    in gRPC Core runtime) to configure the channel.183  compression: An optional value indicating the compression method to be184    used over the lifetime of the channel.185  interceptors: An optional sequence of interceptors that will be executed for186    any call executed with this channel.187 188Returns:189  A Channel.190Nr,)r�)r�r�r2rJs    r.�insecure_channelr�8s&��(���o��7�����r-rjc�>�[UUcSOUURUU5$)aCreates a secure asynchronous Channel to a server.191 192Args:193  target: The server address.194  credentials: A ChannelCredentials instance.195  options: An optional list of key-value pairs (:term:`channel_arguments`196    in gRPC Core runtime) to configure the channel.197  compression: An optional value indicating the compression method to be198    used over the lifetime of the channel.199  interceptors: An optional sequence of interceptors that will be executed for200    any call executed with this channel.201 202Returns:203  An aio.Channel.204r,)r��_credentials)r�rjr�r2rJs     r.�secure_channelr�Us,��,���o��7�� � ����r-)NNN)?r\r)�sys�typingrrrrrrbrr	r205�grpc._cythonr�r
r�_callrrrr�_interceptorrrrrrrrrr�	_metadatar�_typingrrrr r!r"r#�_utilsr$r��__version__r7�version_infor*r/rcr;r=rfrvr{r�r�r�r�r�r�r,r-r.�<module>r�s206��=��207�:�:����!����#�"�"�!�+�5�4�4�3�7�6�6�5��(�*�!�(� �!�(�(�&�-�-�.>�.J�.J�K�����A����(�����.�(�208#�����.�#��%��4<�T�=M�=M�4N��&3�3�l*��
�=�=�*�Z+��
�>�>�+�\*��
�>�>�*�Z*��
�?�?�*�Zw209�m�#�#�w210�x.2�.2�:>�	���
�)�
*���$�*�*�+���8�$5�6�7�	�@.2�.2�:>�����(�(���)�
*���$�*�*�+�	�211�8�$5�6�7�r-
codekingpro/portable-devtools · Team Ai