Ë
    øÿæi4V  ã                   óü  — d Z ddlZddlZddlmZmZmZmZmZ ddl	Z	ddl	m
Z
 ddl	mZ ddl	mZ ddlmZ dd	lmZ dd
lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z  ddl!m"Z" ddl#m$Z$ ddl#m%Z% ddl#m&Z& ddl#m'Z' ddl#m(Z( ddl#m)Z) ddl#m*Z* dd l+m,Z, d!j[                  ej\                  «      Z/ej`                  d   d"k  rd#eejb                     fd$„Z2nd#eejb                     fd%„Z2d&e$d'ee	jf                     fd(„Z4 G d)„ d*«      Z5 G d+„ d,e5ejl                  «      Z6 G d-„ d.e5ejn                  «      Z7 G d/„ d0e5ejp                  «      Z8 G d1„ d2e5ejr                  «      Z9 G d3„ d4ejt                  «      Z:	 	 	 d;d5e;d6ee$   d'ee	jf                     d7eee      fd8„Z<	 	 	 d;d5e;d9e	jz                  d6ee$   d'ee	jf                     d7eee      f
d:„Z>y)<z6Invocation-side implementation of gRPC Asyncio Python.é    N)ÚAnyÚIterableÚListÚOptionalÚSequence)Ú_common)Ú_compression)Ú_grpcio_metadata)Úcygrpcé   )Ú
_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_deadlinezgrpc-python-asyncio/{}é   Úreturnc                  ó>   — t         j                  j                  «       S ©N)ÚasyncioÚTaskÚ	all_tasks© ó    úf/Volumes/fast/ai/experiments/voice-extract-mac/.venv/lib/python3.12/site-packages/grpc/aio/_channel.pyÚ
_all_tasksr/   7   s   € Ü�|‰|×%Ñ%Ó'Ð'r-   c                  ó*   — t        j                  «       S r(   )r)   r+   r,   r-   r.   r/   r/   <   s   € Ü× Ñ Ó"Ð"r-   Úbase_optionsÚcompressionc                 ó�   — t        j                  |«      }t        j                  j                  t
        ff}t        | «      |z   |z   S r(   )r	   Úcreate_channel_optionr   ÚChannelArgKeyÚprimary_user_agent_stringÚ_USER_AGENTÚtuple)r1   r2   Úcompression_channel_argumentÚuser_agent_channel_arguments       r.   Ú_augment_channel_argumentsr;   @   sX   € ô $0×#EÑ#EØó$Ð ô
 × Ñ ×:Ñ:Üð	
ð#Ðô 	ˆlÓØ
&ñ	'à
%ñ	&ðr-   c                   ón  — e Zd ZU dZej
                  ed<   ej                  ed<   e	ed<   e
e   ed<   e
e   ed<   e
ee      ed<   ee   ed<   ej
                  ed<   d	ej                  d
e	de
e   de
e   de
ee      dee   dej
                  ddfd„Ze	 	 dde
e   de
ej*                     defd„«       Zy)Ú_BaseMultiCallablezrBase class of all multi callable objects.

    Handles the initialization logic and stores common attributes.
    Ú_loopÚ_channelÚ_methodÚ_request_serializerÚ_response_deserializerÚ_interceptorsÚ_referencesÚchannelÚmethodÚrequest_serializerÚresponse_deserializerÚinterceptorsÚ
referencesÚloopr&   Nc                 óf   — || _         || _        || _        || _        || _        || _        || _        y r(   )r>   r?   r@   rA   rB   rC   rD   )ÚselfrE   rF   rG   rH   rI   rJ   rK   s           r.   Ú__init__z_BaseMultiCallable.__init__c   s9   € ð ˆŒ
ØˆŒØˆŒØ#5ˆÔ Ø&;ˆÔ#Ø)ˆÔØ%ˆÕr-   Úmetadatar2   c                 óÚ   — | xs
 t        «       } t        | t         «      s.t        | t        «      rt        j                  t	        | «      «      } |rt        t        j                  | |«      Ž } | S )z—Based on the provided values for <metadata> or <compression> initialise the final
        metadata, as it should be used for the current call.
        )r   Ú
isinstancer   Ú
from_tupler8   r	   Úaugment_metadata)rO   r2   s     r.   Ú_init_metadataz!_BaseMultiCallable._init_metadatau   s`   € ð Ò)œx›zˆÜ˜(¤HÔ-´*Ø”hô3
ô  ×*Ñ*¬5°«?Ó;ˆHÙÜÜ×.Ñ.¨x¸ÓEðˆHð ˆr-   )NN)Ú__name__Ú
__module__Ú__qualname__Ú__doc__r)   ÚAbstractEventLoopÚ__annotations__r   Ú
AioChannelÚbytesr   r#   r   r   r   r   r   rN   Ústaticmethodr   ÚgrpcÚCompressionr   rT   r,   r-   r.   r=   r=   S   s#  … ñð
 ×$Ñ$Ó$Ø×ÑÓØƒNØ!Ð"5Ñ6Ó6Ø$Ð%:Ñ;Ó;Ø˜HÐ%6Ñ7Ñ8Ó8Ø�c‘ÓØ×$Ñ$Ó$ð&à×"Ñ"ð&ð ð&ð %Ð%8Ñ9ð	&ð
  (Ð(=Ñ>ð&ð ˜xÐ(9Ñ:Ñ;ð&ð ˜‘Ið&ð ×'Ñ'ð&ð 
ó&ð$ à+/Ø26ñØ˜<Ñ(ðà˜d×.Ñ.Ñ/ðð 
òó ñr-   r=   c                   ó¢   — e Zd Zddddddœdedee   dee   deej                     dee	   deej                     d	ej                  eef   fd
„Zy)ÚUnaryUnaryMultiCallableN©ÚtimeoutrO   ÚcredentialsÚwait_for_readyr2   Úrequestrc   rO   rd   re   r2   r&   c                ó†  — | j                  ||«      }| j                  sQt        |t        |«      |||| j                  | j
                  | j                  | j                  | j                  «
      }|S t        | j                  |||||| j                  | j
                  | j                  | j                  | j                  «      }|S r(   )
rT   rC   r   r$   r?   r@   rA   rB   r>   r   ©rM   rf   rc   rO   rd   re   r2   Úcalls           r.   Ú__call__z UnaryUnaryMultiCallable.__call__Œ   s½   € ð ×&Ñ& x°Ó=ˆØ×!Ò!Ü!ØÜ$ WÓ-ØØØØ—‘Ø—‘Ø×(Ñ(Ø×+Ñ+Ø—
‘
óˆDð6 ˆô -Ø×"Ñ"ØØØØØØ—‘Ø—‘Ø×(Ñ(Ø×+Ñ+Ø—
‘
óˆDð ˆr-   )rU   rV   rW   r!   r   Úfloatr   r^   ÚCallCredentialsÚboolr_   r   r   r"   rj   r,   r-   r.   ra   ra   ‰   s�   „ ð $(Ø+/Ø6:Ø)-Ø26ò'àð'ð ˜%‘ð	'ð
 ˜<Ñ(ð'ð ˜d×2Ñ2Ñ3ð'ð ! ™ð'ð ˜d×.Ñ.Ñ/ð'ð 
×	"Ñ	" ;°Ð#<Ñ	=ô'r-   ra   c                   ó¢   — e Zd Zddddddœdedee   dee   deej                     dee	   deej                     d	ej                  eef   fd
„Zy)ÚUnaryStreamMultiCallableNrb   rf   rc   rO   rd   re   r2   r&   c                ó†  — | j                  ||«      }| j                  sQt        |t        |«      |||| j                  | j
                  | j                  | j                  | j                  «
      }|S t        | j                  |||||| j                  | j
                  | j                  | j                  | j                  «      }|S r(   )
rT   rC   r   r$   r?   r@   rA   rB   r>   r   rh   s           r.   rj   z!UnaryStreamMultiCallable.__call__¹   s½   € ð ×&Ñ& x°Ó=ˆà×!Ò!Ü"ØÜ$ WÓ-ØØØØ—‘Ø—‘Ø×(Ñ(Ø×+Ñ+Ø—
‘
óˆDð6 ˆô .Ø×"Ñ"ØØØØØØ—‘Ø—‘Ø×(Ñ(Ø×+Ñ+Ø—
‘
óˆDð ˆr-   )rU   rV   rW   r!   r   rk   r   r^   rl   rm   r_   r   r   r"   rj   r,   r-   r.   ro   ro   ¶   s�   „ ð $(Ø+/Ø6:Ø)-Ø26ò(àð(ð ˜%‘ð	(ð
 ˜<Ñ(ð(ð ˜d×2Ñ2Ñ3ð(ð ! ™ð(ð ˜d×.Ñ.Ñ/ð(ð 
×	#Ñ	# K°Ð$=Ñ	>ô(r-   ro   c                   óž   — e Zd Z	 	 	 	 	 	 d
dee   dee   dee   deej                     dee	   deej                     dej                  fd	„Zy)ÚStreamUnaryMultiCallableNÚrequest_iteratorrc   rO   rd   re   r2   r&   c                 ó†  — | j                  ||«      }| j                  sQt        |t        |«      |||| j                  | j
                  | j                  | j                  | j                  «
      }|S t        | j                  |||||| j                  | j
                  | j                  | j                  | j                  «      }|S r(   )
rT   rC   r   r$   r?   r@   rA   rB   r>   r   ©rM   rs   rc   rO   rd   re   r2   ri   s           r.   rj   z!StreamUnaryMultiCallable.__call__ç   s½   € ð ×&Ñ& x°Ó=ˆà×!Ò!Ü"Ø Ü$ WÓ-ØØØØ—‘Ø—‘Ø×(Ñ(Ø×+Ñ+Ø—
‘
óˆDð6 ˆô .Ø×"Ñ"Ø ØØØØØ—‘Ø—‘Ø×(Ñ(Ø×+Ñ+Ø—
‘
óˆDð ˆr-   ©NNNNNN)rU   rV   rW   r   r    rk   r   r^   rl   rm   r_   r   r   rj   r,   r-   r.   rr   rr   ä   sŽ   „ ð
 ;?Ø#'Ø+/Ø6:Ø)-Ø26ñ'à"Ð#6Ñ7ð'ð ˜%‘ð'ð ˜<Ñ(ð	'ð
 ˜d×2Ñ2Ñ3ð'ð ! ™ð'ð ˜d×.Ñ.Ñ/ð'ð 
×	#Ñ	#ô'r-   rr   c                   óž   — e Zd Z	 	 	 	 	 	 d
dee   dee   dee   deej                     dee	   deej                     dej                  fd	„Zy)ÚStreamStreamMultiCallableNrs   rc   rO   rd   re   r2   r&   c                 ó†  — | j                  ||«      }| j                  sQt        |t        |«      |||| j                  | j
                  | j                  | j                  | j                  «
      }|S t        | j                  |||||| j                  | j
                  | j                  | j                  | j                  «      }|S r(   )
rT   rC   r   r$   r?   r@   rA   rB   r>   r   ru   s           r.   rj   z"StreamStreamMultiCallable.__call__  s½   € ð ×&Ñ& x°Ó=ˆà×!Ò!Ü#Ø Ü$ WÓ-ØØØØ—‘Ø—‘Ø×(Ñ(Ø×+Ñ+Ø—
‘
óˆDð6 ˆô /Ø×"Ñ"Ø ØØØØØ—‘Ø—‘Ø×(Ñ(Ø×+Ñ+Ø—
‘
óˆDð ˆr-   rv   )rU   rV   rW   r   r    rk   r   r^   rl   rm   r_   r   r   rj   r,   r-   r.   rx   rx     sŽ   „ ð
 ;?Ø#'Ø+/Ø6:Ø)-Ø26ñ'à"Ð#6Ñ7ð'ð ˜%‘ð'ð ˜<Ñ(ð	'ð
 ˜d×2Ñ2Ñ3ð'ð ! ™ð'ð ˜d×.Ñ.Ñ/ð'ð 
×	$Ñ	$ô'r-   rx   c                   óN  — e Zd ZU ej                  ed<   ej                  ed<   ee	   ed<   ee
   ed<   ee   ed<   ee   ed<   deded	eej                      d
eej$                     deee      f
d„Zd„ Zd„ Zd„ Zd#dee   fd„Zd„ Z	 d$dedej:                  fd„Zdej:                  ddfd„Zd%d„Z dede!fd„Z"	 	 	 d&dedee#   dee$   dee   de%f
d„Z&	 	 	 d&dedee#   dee$   dee   de'f
d „Z(	 	 	 d&dedee#   dee$   dee   de)f
d!„Z*	 	 	 d&dedee#   dee$   dee   de+f
d"„Z,y)'ÚChannelr>   r?   Ú_unary_unary_interceptorsÚ_unary_stream_interceptorsÚ_stream_unary_interceptorsÚ_stream_stream_interceptorsÚtargetÚoptionsrd   r2   rI   c                 óž  — g | _         g | _        g | _        g | _        |��Q|D �]K  }t	        |t
        «      r| j                   j                  |«       Œ0t	        |t        «      r| j                  j                  |«       Œ\t	        |t        «      r| j                  j                  |«       Œˆt	        |t        «      r| j                  j                  |«       Œ´t        dj                  |«      dj                  t
        j                  «      z   dj                  t        j                  «      z   dj                  t        j                  «      z   dj                  t        j                  «      z   «      ‚ t        j                  «       | _        t        j                   t#        j$                  |«      t'        ||«      || j                  «      | _        y)aÝ  Constructor.

        Args:
          target: The target to which to connect.
          options: Configuration options for the channel.
          credentials: A cygrpc.ChannelCredentials or None.
          compression: An optional value indicating the compression method to be
            used over the lifetime of the channel.
          interceptors: An optional list of interceptors that would be used for
            intercepting any RPC executed with that channel.
        NzInterceptor {} must be z{} or z{}. )r|   r}   r~   r   rQ   r   Úappendr   r   r   Ú
ValueErrorÚformatrU   r   Úget_working_loopr>   r[   r   Úencoder;   r?   )rM   r€   r�   rd   r2   rI   Úinterceptors          r.   rN   zChannel.__init__F  sw  € ð& *,ˆÔ&Ø*,ˆÔ'Ø*,ˆÔ'Ø+-ˆÔ(àÑ#Ü+�Ü˜kÔ+FÔGØ×2Ñ2×9Ñ9¸+ÕFÜ Ô-IÔJØ×3Ñ3×:Ñ:¸;ÕGÜ Ô-IÔJØ×3Ñ3×:Ñ:¸;ÕGÜ Ô-JÔ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óð ð  ,ô$ ×,Ñ,Ó.ˆŒ
Ü×)Ñ)Ü�N‰N˜6Ó"Ü& w°Ó<ØØ�J‰Jó	
ˆ�r-   c              ƒ   ó   K  — | S ­wr(   r,   ©rM   s    r.   Ú
__aenter__zChannel.__aenter__y  s   è ø€ Øˆùs   ‚c              ƒ   óB   K  — | j                  d «      ƒ d {  –—†  y 7 Œ­wr(   ©Ú_close)rM   Úexc_typeÚexc_valÚexc_tbs       r.   Ú	__aexit__zChannel.__aexit__|  s   è ø€ Ø�k‰k˜$Ó×Òúó   ‚—˜c              ƒ   ó^  K  — | j                   j                  «       ry | j                   j                  «        t        «       }g }g }|D ]æ  }	 |j	                  d¬«      }|sŒ|d   }|j                  j                  d«      }	|	€Œ<t        |	t        j                  «      sŒWt        |	d«      r|	j                   | j                   urJŒ|t        |	d«      r#|	j                  j                   | j                   urŒ«d|	› �}
t        j                  |
«      ‚|j!                  |	«       |j!                  |«       Œè |r!|rt#        j$                  ||¬	«      ƒ d {  –—†  |D ]  }|j'                  «        Œ | j                   j)                  «        y # t
        $ r}dt        |«      v rY d }~�ŒZ‚ d }~ww xY w7 Œ[­w)
Nr   )ÚlimitÚframer   rM   r?   Ú_cython_callzUnrecognized call object: )rc   )r?   ÚclosedÚclosingr/   Ú	get_stackÚAttributeErrorÚstrÚf_localsÚgetrQ   r   ÚCallÚhasattrr—   r   ÚInternalErrorrƒ   r)   ÚwaitÚcancelÚclose)rM   ÚgraceÚtasksÚcallsÚ
call_tasksÚtaskÚstackÚattribute_errorr–   Ú	candidateÚ	error_msgri   s               r.   rŽ   zChannel._close  sˆ  è ø€ Ø�=‰=×ÑÔ!Øð 	�‰×ÑÔô “ˆØˆØˆ
ÛˆDðØŸ™¨Q˜Ó/�ñ* Øð ˜!‘HˆEØŸ™×*Ñ*¨6Ó2ˆIð Ñ$¬°I¼z¿¹Õ)OÜ˜9 jÔ1à ×)Ñ)°·±Ñ>Ø Ü˜Y¨Ô7à ×-Ñ-×6Ñ6¸d¿m¹mÑKØ ð #=¸Y¸KÐ H�IÜ ×.Ñ.¨yÓ9Ð9à—‘˜YÔ'Ø×!Ñ! $Õ'ð_ ñf ‘ZÜ—,‘,˜z°5Ô9×9Ð9ó ˆDØ�K‰K�Mð ð 	�‰×ÑÕøôq "ò ð œc /Ó2Ñ2ÝØûð#úðb :úsO   ‚A	F-ÁFÁ%F-ÂF-ÂB0F-ÅF+Å6F-Æ	F(ÆF#ÆF-Æ"F#Æ#F(Æ(F-Nr¥   c              ƒ   óB   K  — | j                  |«      ƒ d {  –—†  y 7 Œ­wr(   r�   )rM   r¥   s     r.   r¤   zChannel.closeÇ  s   è ø€ Ø�k‰k˜%Ó × Ò úr“   c                 óˆ   — t        | d«      r6| j                  j                  «       s| j                  j                  «        y y y )Nr?   )r    r?   r˜   r¤   rŠ   s    r.   Ú__del__zChannel.__del__Ê  s4   € Ü�4˜Ô$¨T¯]©]×-AÑ-AÔ-CØ�M‰M×ÑÕ!ð .DÐ$r-   Útry_to_connectr&   c                 ó^   — | j                   j                  |«      }t        j                  |   S r(   )r?   Úcheck_connectivity_stater   Ú1CYGRPC_CONNECTIVITY_STATE_TO_CHANNEL_CONNECTIVITY)rM   r±   Úresults      r.   Ú	get_statezChannel.get_stateÎ  s)   € ð —‘×7Ñ7¸ÓGˆÜ×HÑHÈÑPÐPr-   Úlast_observed_statec              ƒ   óv   K  — | j                   j                  |j                  d   d «      ƒ d {  –—† sJ ‚y 7 Œ­w)Nr   )r?   Úwatch_connectivity_stateÚvalue)rM   r·   s     r.   Úwait_for_state_changezChannel.wait_for_state_changeÔ  s>   è ø€ ð —]‘]×;Ñ;Ø×%Ñ% aÑ(¨$ó
÷ 
ð 
ð 	
ò 
ús   ‚-9¯7°9c              ƒ   ó  K  — | j                  d¬«      }|t        j                  j                  k7  rJ| j	                  |«      ƒ d {  –—†  | j                  d¬«      }|t        j                  j                  k7  rŒIy y 7 Œ6­w)NT)r±   )r¶   r^   ÚChannelConnectivityÚREADYr»   )rM   Ústates     r.   Úchannel_readyzChannel.channel_readyÜ  sg   è ø€ Ø—‘¨d�Ó3ˆØ”t×/Ñ/×5Ñ5Ò5Ø×,Ñ,¨UÓ3×3Ð3Ø—N‘N°$�NÓ7ˆEð ”t×/Ñ/×5Ñ5Õ5Ø3ús   ‚AA?ÁA=Á3A?Á;A?rF   c                  ó   — y r(   r,   )rM   rF   s     r.   Ú_get_registered_call_handlez#Channel._get_registered_call_handleä  s   € Ør-   rG   rH   Ú_registered_methodc           	      óˆ   — t        | j                  t        j                  |«      ||| j                  | g| j
                  «      S r(   )ra   r?   r   r‡   r|   r>   ©rM   rF   rG   rH   rÃ   s        r.   Úunary_unaryzChannel.unary_unaryê  s?   € ô 'Ø�M‰MÜ�N‰N˜6Ó"ØØ!Ø×*Ñ*ØˆFØ�J‰Jó
ð 	
r-   c           	      óˆ   — t        | j                  t        j                  |«      ||| j                  | g| j
                  «      S r(   )ro   r?   r   r‡   r}   r>   rÅ   s        r.   Úunary_streamzChannel.unary_streamþ  ó?   € ô (Ø�M‰MÜ�N‰N˜6Ó"ØØ!Ø×+Ñ+ØˆFØ�J‰Jó
ð 	
r-   c           	      óˆ   — t        | j                  t        j                  |«      ||| j                  | g| j
                  «      S r(   )rr   r?   r   r‡   r~   r>   rÅ   s        r.   Ústream_unaryzChannel.stream_unary  rÉ   r-   c           	      óˆ   — t        | j                  t        j                  |«      ||| j                  | g| j
                  «      S r(   )rx   r?   r   r‡   r   r>   rÅ   s        r.   Ústream_streamzChannel.stream_stream&  s?   € ô )Ø�M‰MÜ�N‰N˜6Ó"ØØ!Ø×,Ñ,ØˆFØ�J‰Jó
ð 	
r-   r(   )F)r&   N)NNF)-rU   rV   rW   r)   rY   rZ   r   r[   r   r   r   r   r   rœ   r   r   ÚChannelCredentialsr^   r_   r   r   rN   r‹   r’   rŽ   rk   r¤   r°   rm   r½   r¶   r»   rÀ   ÚintrÂ   r#   r   ra   rÆ   ro   rÈ   rr   rË   rx   rÍ   r,   r-   r.   r{   r{   >  sc  … Ø×$Ñ$Ó$Ø×ÑÓØ#Ð$?Ñ@Ó@Ø $Ð%AÑ BÓBØ $Ð%AÑ BÓBØ!%Ð&CÑ!DÓDð1
àð1
ð %ð1
ð ˜f×7Ñ7Ñ8ð	1
ð
 ˜d×.Ñ.Ñ/ð1
ð ˜xÐ(9Ñ:Ñ;ó1
òfò òFñP! ¨%¡ó !ò"ð
 &+ñQØ"ðQà	×	!Ñ	!óQð
à!×5Ñ5ð
ð 
ó
ó8ð°#ð ¸#ó ð =AØAEØ-2ñ
àð
ð %Ð%8Ñ9ð
ð  (Ð(=Ñ>ð	
ð
 % T™Nð
ð 
!ó
ð. =AØAEØ-2ñ
àð
ð %Ð%8Ñ9ð
ð  (Ð(=Ñ>ð	
ð
 % T™Nð
ð 
"ó
ð. =AØAEØ-2ñ
àð
ð %Ð%8Ñ9ð
ð  (Ð(=Ñ>ð	
ð
 % T™Nð
ð 
"ó
ð. =AØAEØ-2ñ
àð
ð %Ð%8Ñ9ð
ð  (Ð(=Ñ>ð	
ð
 % T™Nð
ð 
#ô
r-   r{   r€   r�   rI   c                 ó(   — t        | |€dn|d||«      S )a  Creates an insecure asynchronous Channel to a server.

    Args:
      target: The server address
      options: An optional list of key-value pairs (:term:`channel_arguments`
        in gRPC Core runtime) to configure the channel.
      compression: An optional value indicating the compression method to be
        used over the lifetime of the channel.
      interceptors: An optional sequence of interceptors that will be executed for
        any call executed with this channel.

    Returns:
      A Channel.
    Nr,   )r{   )r€   r�   r2   rI   s       r.   Úinsecure_channelrÑ   8  s&   € ô( ØØˆo‰ 7ØØØóð r-   rd   c                 ó<   — t        | |€dn||j                  ||«      S )a<  Creates a secure asynchronous Channel to a server.

    Args:
      target: The server address.
      credentials: A ChannelCredentials instance.
      options: An optional list of key-value pairs (:term:`channel_arguments`
        in gRPC Core runtime) to configure the channel.
      compression: An optional value indicating the compression method to be
        used over the lifetime of the channel.
      interceptors: An optional sequence of interceptors that will be executed for
        any call executed with this channel.

    Returns:
      An aio.Channel.
    r,   )r{   Ú_credentials)r€   rd   r�   r2   rI   s        r.   Úsecure_channelrÔ   U  s,   € ô, ØØˆo‰ 7Ø× Ñ ØØóð r-   )NNN)?rX   r)   ÚsysÚtypingr   r   r   r   r   r^   r   r	   r
   Úgrpc._cythonr   Ú r   r   Ú_callr   r   r   r   Ú_interceptorr   r   r   r   r   r   r   r   r   Ú	_metadatar   Ú_typingr   r   r   r    r!   r"   r#   Ú_utilsr$   r…   Ú__version__r7   Úversion_infor*   r/   r_   r;   r=   ra   ro   rr   rx   r{   rœ   rÑ   rÎ   rÔ   r,   r-   r.   Ú<module>rà      s
  ðñ =ã Û 
ß :Õ :ã Ý Ý Ý !Ý å Ý Ý #Ý "Ý "Ý !Ý +Ý 5Ý 4Ý 4Ý 3Ý 7Ý 6Ý 6Ý 5Ý Ý (Ý *Ý !Ý (Ý  Ý !Ý (Ý (à&×-Ñ-Ð.>×.JÑ.JÓK€à×Ñ�AÑ˜Òð(˜ §¡Ñ.ô (ð
#˜ §¡Ñ.ó #ðØ%ðØ4<¸T×=MÑ=MÑ4Nó÷&3ñ 3ôl*Ø˜×=Ñ=ô*ôZ+Ø˜×>Ñ>ô+ô\*Ø˜×>Ñ>ô*ôZ*Ø˜×?Ñ?ô*ôZw
ˆm×#Ñ#ô w
ðx .2Ø.2Ø:>ñ	ØðàÐ)Ñ*ðð ˜$×*Ñ*Ñ+ðð ˜8Ð$5Ñ6Ñ7ó	ð@ .2Ø.2Ø:>ñØðà×(Ñ(ðð Ð)Ñ*ðð ˜$×*Ñ*Ñ+ð	ð
 ˜8Ð$5Ñ6Ñ7ôr-   