+
    id                     v   R t ^ RIt^ RIt^ RIt^ RIHtHtHtHtH	t	H
t
 ^ RIt^RIHt ^RIHt ^RIHt ^RIHt ^RIHt  ! R R	]4      tR
 R lt ! R R]P*                  ! RR 4      ]P,                  4      tR R lt ! R R]P2                  ]P4                  ]P6                  4      t ! R R]P6                  ]P4                  4      t ! R R]P<                  4      t ! R R]P@                  4      t! ! R R]PD                  4      t# ! R R]PH                  4      t% ! R R]PL                  4      t'R R lt(R# )!z+Implementation of gRPC Python interceptors.N)AnyCallableOptionalSequenceTupleUnion)DeserializingFunctionDoneCallbackType)MetadataType)RequestIterableType)SerializingFunctionc                   t   a  ] tR t^t o V 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltV 3R	 ltR
t	V t
R# )_ServicePipelinec                D   < V ^8  d   QhRS[ S[P                  ,          /#    interceptors)r   grpcServerInterceptor)format__classdict__s   "d/Users/igloo/.openclaw/workspace/scratch/fb_ad_env/lib/python3.14/site-packages/grpc/_interceptor.py__annotate___ServicePipeline.__annotate__!   s     0 0Xd.D.D%E 0    c                &    \        V4      V n        R # N)tupler   )selfr   s   &&r   __init___ServicePipeline.__init__!   s    !,/r   c                ,   < V ^8  d   QhRS[ RS[RS[ /# )r   thunkindexreturn)r   int)r   r   s   "r   r   r   $   s'     I I8 IC IH Ir   c                   a aa VV V3R  l# )c                 *   < SP                  SSV 4      # r   _intercept_at)contextr$   r   r#   s   &r   <lambda>0_ServicePipeline._continuation.<locals>.<lambda>%   s    t11%Hr    )r   r#   r$   s   fffr   _continuation_ServicePipeline._continuation$   s	    HHr   c                Z   < V ^8  d   QhRS[ RS[RS[P                  RS[P                  /# )r   r#   r$   r+   r%   )r   r&   r   HandlerCallDetailsRpcMethodHandler)r   r   s   "r   r   r   '   s9      &)484K4K			r   c                    V\        V P                  4      8  d=   V P                  V,          pV P                  W^,           4      pVP                  W4      # V! V4      # )   )lenr   r/   intercept_service)r   r#   r$   r+   interceptors   &&&& r   r*   _ServicePipeline._intercept_at'   sV     3t(())++E2K&&uai8E00@@W~r   c                T   < V ^8  d   QhRS[ RS[P                  RS[P                  /# )r   r#   r+   r%   )r   r   r2   r3   )r   r   s   "r   r   r   0   s1     5 55(,(?(?5			5r   c                (    V P                  V^ V4      # )    r)   )r   r#   r+   s   &&&r   execute_ServicePipeline.execute0   s     !!%G44r   c                J   < V ^8  d   Qh/ S[ S[P                  ,          ;R&   # r   )r   r   r   )r   r   s   "r   r   r      s     ..// r   r   N)__name__
__module____qualname____firstlineno__r    r/   r*   r=   __annotate_func____static_attributes____classdictcell__r   s   @r   r   r      s6     0 0I I 5 5%  r   r   c                    V ^8  d   QhR\         \        \        P                  ,          ,          R\         \        ,          /# )r   r   r%   )r   r   r   r   r   )r   s   "r   r   r   6   s6     D D8D$:$:;<DDr   c                 ,    V '       d   \        V 4      # R # r   )r   r@   s   &r   service_pipelinerK   6   s     .:L)CtCr   c                       ] tR t^<tRtR# )_ClientCallDetailsr.   N)rA   rB   rC   rD   rF   r.   r   r   rM   rM   <   s     	r   rM   c                    V ^8  d   QhR\         P                  R\         P                  R\        \        \        \
        \         P                  \        \         P                  3,          /# )r   call_detailsdefault_detailsr%   )	r   ClientCallDetailsr   strfloatr   CallCredentialsboolCompression)r   s   "r   r   r   M   sX     0O 0O((0O++0O d22D$:J:JJ0Or   c                     V P                   p V P                  p V P                  p V P                  p V P
                  p V P                  pW#WEWg3#   \         d    TP                   p L_i ; i  \         d    TP                  p Loi ; i  \         d    TP                  p Li ; i  \         d    TP                  p Li ; i  \         d    TP
                  p Li ; i  \         d    TP                  p Li ; ir   )methodAttributeErrortimeoutmetadatacredentialswait_for_readycompression)rO   rP   rX   rZ   r[   r\   r]   r^   s   &&      r   _unwrap_client_call_detailsr_   M   s'   ($$*&&,((
$$ 	
'' 	
$$ 	 H>NNQ  ( ''(
  *!))*
  ,"++,  
'' 	
  
** 	
  
'' 	
sg   A A1 B B+ C C% A.-A.1B
BB('B(+CCC"!C"%C?>C?c                   v  a a ] tR t^t oV3R lV 3R lltV3R lR ltV3R lR ltV3R lR ltV3R	 lR
 ltV3R lR lt	V3R lR lt
V3R lR ltV3R lR ltV3R lR ltV3R lR ltR&V3R lR lltR&V3R lR lltR&V3R lR lltV3R lR ltV3R lR  ltR! tR" tR# tV3R$ ltR%tVtV ;t# )'_FailureOutcomec                :   < V ^8  d   QhRS[ RS[P                  /# )r   	exception	traceback	ExceptiontypesTracebackType)r   r   s   "r   r   _FailureOutcome.__annotate__   s!     $ $) $8K8K $r   c                D   < \         \        V `  4        Wn        W n        R # r   )superra   r    
_exception
_traceback)r   rc   rd   	__class__s   &&&r   r    _FailureOutcome.__init__   s    ot-/##r   c                0   < V ^8  d   QhRS[ S[,          /# r   r%   r   r   )r   r   s   "r   r   ri      s      (<"8 r   c                    R # r   r.   r   s   &r   initial_metadata _FailureOutcome.initial_metadata       r   c                0   < V ^8  d   QhRS[ S[,          /# rq   rr   )r   r   s   "r   r   ri      s      8L#9 r   c                    R # r   r.   rt   s   &r   trailing_metadata!_FailureOutcome.trailing_metadata   rw   r   c                D   < V ^8  d   QhRS[ S[P                  ,          /# rq   r   r   
StatusCode)r   r   s   "r   r   ri      s     ( (ht/ (r   c                6    \         P                  P                  # r   )r   r~   INTERNALrt   s   &r   code_FailureOutcome.code   s    '''r   c                0   < V ^8  d   QhRS[ S[,          /# rq   r   rR   )r   r   s   "r   r   ri      s     = =# =r   c                    R # )z+Exception raised while intercepting the RPCr.   rt   s   &r   details_FailureOutcome.details   s    <r   c                    < V ^8  d   QhRS[ /# rq   rU   )r   r   s   "r   r   ri      s       r   c                    R # Fr.   rt   s   &r   cancel_FailureOutcome.cancel       r   c                    < V ^8  d   QhRS[ /# rq   r   )r   r   s   "r   r   ri            4 r   c                    R # r   r.   rt   s   &r   	cancelled_FailureOutcome.cancelled   r   r   c                    < V ^8  d   QhRS[ /# rq   r   )r   r   s   "r   r   ri      r   r   c                    R # r   r.   rt   s   &r   	is_active_FailureOutcome.is_active   r   r   c                0   < V ^8  d   QhRS[ S[,          /# rq   r   rS   )r   r   s   "r   r   ri      s       r   c                    R # r   r.   rt   s   &r   time_remaining_FailureOutcome.time_remaining   rw   r   c                    < V ^8  d   QhRS[ /# rq   r   )r   r   s   "r   r   ri             r   c                    R # r   r.   rt   s   &r   running_FailureOutcome.running   r   r   c                    < V ^8  d   QhRS[ /# rq   r   )r   r   s   "r   r   ri            d r   c                    R # Tr.   rt   s   &r   done_FailureOutcome.done   rw   r   c                0   < V ^8  d   QhRS[ S[,          /# r   ignored_timeoutr   )r   r   s   "r   r   ri            huo r   c                    V P                   hr   rl   r   r   s   &&r   result_FailureOutcome.result       oor   c                F   < V ^8  d   QhRS[ S[,          RS[ S[,          /# r   r   r%   )r   rS   rf   )r   r   s   "r   r   ri      s&      '	)	r   c                    V P                   # r   r   r   s   &&r   rc   _FailureOutcome.exception        r   c                Z   < V ^8  d   QhRS[ S[,          RS[ S[P                  ,          /# r   )r   rS   rg   rh   )r   r   s   "r   r   ri      s,      '	%%%	&r   c                    V P                   # r   )rm   r   s   &&r   rd   _FailureOutcome.traceback   r   r   c                    < V ^8  d   QhRS[ /# rq   r   )r   r   s   "r   r   ri      s      t r   c                    R # r   r.   )r   unused_callbacks   &&r   add_callback_FailureOutcome.add_callback   r   r   c                $   < V ^8  d   QhRS[ RR/# r   fnr%   Nr	   )r   r   s   "r   r   ri            $4  r   c                    V! V 4       R # r   r.   r   r   s   &&r   add_done_callback!_FailureOutcome.add_done_callback   	    
4r   c                    V # r   r.   rt   s   &r   __iter___FailureOutcome.__iter__       r   c                    V P                   hr   r   rt   s   &r   __next___FailureOutcome.__next__   r   r   c                "    V P                  4       # r   )r   rt   s   &r   next_FailureOutcome.next   s    }}r   c                F   < V ^8  d   Qh/ S[ ;R&   S[P                  ;R&   # )r   rl   rm   re   )r   r   s   "r   r   ri      s%        ###	 r   )rl   rm   r   )rA   rB   rC   rD   r    ru   rz   r   r   r   r   r   r   r   r   r   rc   rd   r   r   r   r   r   rE   rF   rG   __classcell__)rn   r   s   @@r   ra   ra      s     $ $
  ( (= =        
 
  E  r   ra   c                   X  a  ] tR t^t o V 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltV 3R	 lR
 ltV 3R lR lt	V 3R lR lt
V 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltR$V 3R lR lltR$V 3R lR lltR$V 3R lR lltV 3R  lR! ltV 3R" ltR#tV tR# )%_UnaryOutcomec                :   < V ^8  d   QhRS[ RS[P                  /# )r   responsecallr   r   Call)r   r   s   "r   r   _UnaryOutcome.__annotate__   s       DII r   c                    Wn         W n        R # r   )	_response_call)r   r   r   s   &&&r   r    _UnaryOutcome.__init__   s    !
r   c                0   < V ^8  d   QhRS[ S[,          /# rq   rr   )r   r   s   "r   r   r      s     - -(<"8 -r   c                6    V P                   P                  4       # r   )r   ru   rt   s   &r   ru   _UnaryOutcome.initial_metadata   s    zz**,,r   c                0   < V ^8  d   QhRS[ S[,          /# rq   rr   )r   r   s   "r   r   r      s     . .8L#9 .r   c                6    V P                   P                  4       # r   )r   rz   rt   s   &r   rz   _UnaryOutcome.trailing_metadata   s    zz++--r   c                D   < V ^8  d   QhRS[ S[P                  ,          /# rq   r}   )r   r   s   "r   r   r      s     ! !ht/ !r   c                6    V P                   P                  4       # r   )r   r   rt   s   &r   r   _UnaryOutcome.code   s    zz  r   c                0   < V ^8  d   QhRS[ S[,          /# rq   r   )r   r   s   "r   r   r      s     $ $# $r   c                6    V P                   P                  4       # r   )r   r   rt   s   &r   r   _UnaryOutcome.details   s    zz!!##r   c                    < V ^8  d   QhRS[ /# rq   r   )r   r   s   "r   r   r      s     & &4 &r   c                6    V P                   P                  4       # r   )r   r   rt   s   &r   r   _UnaryOutcome.is_active   s    zz##%%r   c                0   < V ^8  d   QhRS[ S[,          /# rq   r   )r   r   s   "r   r   r      s     + + +r   c                6    V P                   P                  4       # r   )r   r   rt   s   &r   r   _UnaryOutcome.time_remaining   s    zz((**r   c                    < V ^8  d   QhRS[ /# rq   r   )r   r   s   "r   r   r      s     # # #r   c                6    V P                   P                  4       # r   )r   r   rt   s   &r   r   _UnaryOutcome.cancel   s    zz  ""r   c                    < V ^8  d   QhRS[ /# rq   r   )r   r   s   "r   r   r      s     1 1 1r   c                8    V P                   P                  V4      # r   )r   r   r   callbacks   &&r   r   _UnaryOutcome.add_callback   s    zz&&x00r   c                    < V ^8  d   QhRS[ /# rq   r   )r   r   s   "r   r   r      r   r   c                    R # r   r.   rt   s   &r   r   _UnaryOutcome.cancelled   r   r   c                    < V ^8  d   QhRS[ /# rq   r   )r   r   s   "r   r   r      r   r   c                    R # r   r.   rt   s   &r   r   _UnaryOutcome.running   r   r   c                    < V ^8  d   QhRS[ /# rq   r   )r   r   s   "r   r   r      r   r   c                    R # r   r.   rt   s   &r   r   _UnaryOutcome.done   rw   r   Nc                0   < V ^8  d   QhRS[ S[,          /# r   r   )r   r   s   "r   r   r      r   r   c                    V P                   # r   )r   r   s   &&r   r   _UnaryOutcome.result   s    ~~r   c                0   < V ^8  d   QhRS[ S[,          /# r   r   )r   r   s   "r   r   r            % r   c                    R # r   r.   r   s   &&r   rc   _UnaryOutcome.exception   rw   r   c                0   < V ^8  d   QhRS[ S[,          /# r   r   )r   r   s   "r   r   r      r  r   c                    R # r   r.   r   s   &&r   rd   _UnaryOutcome.traceback   rw   r   c                $   < V ^8  d   QhRS[ RR/# r   r	   )r   r   s   "r   r   r      r   r   c                    V! V 4       R # r   r.   r   s   &&r   r   _UnaryOutcome.add_done_callback   r   r   c                F   < V ^8  d   Qh/ S[ ;R&   S[P                  ;R&   # )r   r   r   r   )r   r   s   "r   r   r      s     N 99 r   )r   r   r   )rA   rB   rC   rD   r    ru   rz   r   r   r   r   r   r   r   r   r   r   rc   rd   r   rE   rF   rG   rH   s   @r   r   r      s      - -. .! !$ $& &+ +# #1 1       e  r   r   c                      a  ] tR t^t o V 3R lR ltRV 3R lR lltRV 3R lR lltRV 3R lR	 lltRV 3R
 lR lltV 3R lt	Rt
V tR# )_UnaryUnaryMultiCallablec                @   < V ^8  d   QhRS[ RS[RS[P                  /# r   r#   rX   r8   r   rR   r   UnaryUnaryClientInterceptor)r   r   s   "r   r   %_UnaryUnaryMultiCallable.__annotate__  s/     ( (( ( 55	(r   c                *    Wn         W n        W0n        R # r   _thunk_method_interceptorr   r#   rX   r8   s   &&&&r   r    !_UnaryUnaryMultiCallable.__init__       'r   Nc                   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[P
                  ,          RS[S[,          RS[S[P                  ,          RS[ /# r   requestrZ   r[   r\   r]   r^   r%   r   r   rS   r   r   rT   rU   rV   )r   r   s   "r   r   r    st       % <(	
 d223 ! d../ 
r   c           	     8    V P                  VVVVVVR 7      w  rxV# rZ   r[   r\   r]   r^   
_with_call)	r   r"  rZ   r[   r\   r]   r^   r   ignored_calls	   &&&&&&&  r   __call__!_UnaryUnaryMultiCallable.__call__  s3     "&#)# "1 "
 r   c                   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[P
                  ,          RS[S[,          RS[S[P                  ,          RS[S[ S[P                  3,          /# r!  
r   r   rS   r   r   rT   rU   rV   r   r   )r   r   s   "r   r   r    s     -# -#-# %-# <(	-#
 d223-# !-# d../-# 
sDII~	-#r   c                   a a	 \        S P                  VVVVV4      o	V	V 3R  lpS P                  P                  VS	V4      pVP	                  4       V3# )c           	      L  < \        V S4      w  pppppp SP                  V4      P                  VVVVVVR 7      w  r\        W4      #   \        P
                   d   p
T
u Rp
?
# Rp
?
i\         d1   p\        T\        P                  ! 4       ^,          4      u Rp?# Rp?ii ; ir&  N
r_   r  	with_callr   r   RpcErrorrf   ra   sysexc_info)new_detailsr"  
new_methodnew_timeoutnew_metadatanew_credentialsnew_wait_for_readynew_compressionr   r   	rpc_errorrc   client_call_detailsr   s   &&          r   continuation9_UnaryUnaryMultiCallable._with_call.<locals>.continuation0  s     ,K9LM"E!%Z!8!B!B') /#5 / "C " %X44== !   E&y#,,.2CDDE5   2A	 	B#A%B#%B#2B#3%BB#B#)rM   r  r  intercept_unary_unaryr   )
r   r"  rZ   r[   r\   r]   r^   r?  r   r>  s
   f&&&&&&  @r   r(  #_UnaryUnaryMultiCallable._with_call  s_     1LL
	E0   66-w
 {{}d""r   c                   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[P
                  ,          RS[S[,          RS[S[P                  ,          RS[S[ S[P                  3,          /# r!  r-  )r   r   s   "r   r   r  M  s     
 

 %
 <(	

 d223
 !
 d../
 
sDII~	
r   c           	     0    V P                  VVVVVVR 7      # r%  r'  )r   r"  rZ   r[   r\   r]   r^   s   &&&&&&&r   r2  "_UnaryUnaryMultiCallable.with_callM  s,     #)#  
 	
r   c                   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[P
                  ,          RS[S[,          RS[S[P                  ,          RS[ /# r!  r#  )r   r   s   "r   r   r  _  s}     )A )A)A %)A <(	)A
 d223)A !)A d../)A 
)Ar   c                   a a	 \        S P                  VVVVV4      o	V	V 3R  lp S P                  P                  VS	V4      #   \         d1   p\        T\        P                  ! 4       ^,          4      u Rp?# Rp?ii ; i)c           	      v   < \        V S4      w  ppppppS	P                  V4      P                  VVVVVVR 7      # r%  r_   r  future
r6  r"  r7  r8  r9  r:  r;  r<  r>  r   s
   &&      r   r?  5_UnaryUnaryMultiCallable.future.<locals>.continuationq  sZ     ,K9LM";;z*11#%+1+ 2  r   N)rM   r  r  rB  rf   ra   r4  r5  
r   r"  rZ   r[   r\   r]   r^   r?  rc   r>  s
   f&&&&&&  @r   rK  _UnaryUnaryMultiCallable.future_  s~     1LL
	$	A$$::17   	A"9cllnQ.?@@	A   A A=%A82A=8A=c                R   < V ^8  d   Qh/ S[ ;R&   S[;R&   S[P                  ;R&   # r   r  r  r  r  )r   r   s   "r   r   r     s-      L  222 r   r  r  r  NNNNNrA   rB   rC   rD   r    r*  r(  r2  rK  rE   rF   rG   rH   s   @r   r  r     B     
( ( &-# -#^
 
$)A )AG  r   r  c                   T   a  ] tR tRt o V 3R lR ltR	V 3R lR lltV 3R ltRtV tR# )
_UnaryStreamMultiCallablei  c                @   < V ^8  d   QhRS[ RS[RS[P                  /# r  r   rR   r   UnaryStreamClientInterceptor)r   r   s   "r   r   &_UnaryStreamMultiCallable.__annotate__  /     ( (( ( 66	(r   c                *    Wn         W n        W0n        R # r   r  r  s   &&&&r   r    "_UnaryStreamMultiCallable.__init__  r  r   Nc                   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[P
                  ,          RS[S[,          RS[S[P                  ,          /# )r   r"  rZ   r[   r\   r]   r^   r#  )r   r   s   "r   r   r\    sr     )A )A)A %)A <(	)A
 d223)A !)A d../)Ar   c                   a a	 \        S P                  VVVVV4      o	V	V 3R  lp S P                  P                  VS	V4      #   \         d1   p\        T\        P                  ! 4       ^,          4      u Rp?# Rp?ii ; i)c           	      d   < \        V S4      w  ppppppS	P                  V4      ! VVVVVVR 7      # r%  r_   r  rL  s
   &&      r   r?  8_UnaryStreamMultiCallable.__call__.<locals>.continuation  sO     ,K9LM";;z*#%+1+ r   N)rM   r  r  intercept_unary_streamrf   ra   r4  r5  rN  s
   f&&&&&&  @r   r*  "_UnaryStreamMultiCallable.__call__  s~     1LL
	$	A$$;;17   	A"9cllnQ.?@@	ArP  c                R   < V ^8  d   Qh/ S[ ;R&   S[;R&   S[P                  ;R&   # rR  rZ  )r   r   s   "r   r   r\    -      L  333 r   rS  rT  	rA   rB   rC   rD   r    r*  rE   rF   rG   rH   s   @r   rX  rX    "     
( ()A )A  r   rX  c                      a  ] tR tRt o V 3R lR ltRV 3R lR lltRV 3R lR lltRV 3R	 lR
 lltRV 3R lR lltV 3R lt	Rt
V tR# )_StreamUnaryMultiCallablei  c                @   < V ^8  d   QhRS[ RS[RS[P                  /# r  r   rR   r   StreamUnaryClientInterceptor)r   r   s   "r   r   &_StreamUnaryMultiCallable.__annotate__  r]  r   c                *    Wn         W n        W0n        R # r   r  r  s   &&&&r   r    "_StreamUnaryMultiCallable.__init__  r  r   Nc                   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[P
                  ,          RS[S[,          RS[S[P                  ,          RS[/# r   request_iteratorrZ   r[   r\   r]   r^   r%   	r   r   rS   r   r   rT   rU   rV   r   )r   r   s   "r   r   rp    st      - % <(	
 d223 ! d../ 
r   c           	     8    V P                  VVVVVVR 7      w  rxV# r%  r'  )	r   ru  rZ   r[   r\   r]   r^   r   r)  s	   &&&&&&&  r   r*  "_StreamUnaryMultiCallable.__call__  s3     "&#)# "1 "
 r   c                   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[P
                  ,          RS[S[,          RS[S[P                  ,          RS[S[	S[P                  3,          /# rt  r   r   rS   r   r   rT   rU   rV   r   r   r   )r   r   s   "r   r   rp    s     -# -#--# %-# <(	-#
 d223-# !-# d../-# 
sDII~	-#r   c                   a a	 \        S P                  VVVVV4      o	V	V 3R  lpS P                  P                  VS	V4      pVP	                  4       V3# )c           	      L  < \        V S4      w  pppppp SP                  V4      P                  VVVVVVR 7      w  r\        W4      #   \        P
                   d   p
T
u Rp
?
# Rp
?
i\         d1   p\        T\        P                  ! 4       ^,          4      u Rp?# Rp?ii ; ir0  r1  )r6  ru  r7  r8  r9  r:  r;  r<  r   r   r=  rc   r>  r   s   &&          r   r?  :_StreamUnaryMultiCallable._with_call.<locals>.continuation  s     ,K9LM"E!%Z!8!B!B$') /#5 / "C " %X44== !   E&y#,,.2CDDErA  )rM   r  r  intercept_stream_unaryr   )
r   ru  rZ   r[   r\   r]   r^   r?  r   r>  s
   f&&&&&&  @r   r(  $_StreamUnaryMultiCallable._with_call  s`     1LL
	E0   77-/?
 {{}d""r   c                   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[P
                  ,          RS[S[,          RS[S[P                  ,          RS[S[	S[P                  3,          /# rt  rz  )r   r   s   "r   r   rp    s     
 
-
 %
 <(	

 d223
 !
 d../
 
sDII~	
r   c           	     0    V P                  VVVVVVR 7      # r%  r'  )r   ru  rZ   r[   r\   r]   r^   s   &&&&&&&r   r2  #_StreamUnaryMultiCallable.with_call  s,     #)#  
 	
r   c                   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[P
                  ,          RS[S[,          RS[S[P                  ,          RS[/# rt  rv  )r   r   s   "r   r   rp  )  s}     )A )A-)A %)A <(	)A
 d223)A !)A d../)A 
)Ar   c                   a a	 \        S P                  VVVVV4      o	V	V 3R  lp S P                  P                  VS	V4      #   \         d1   p\        T\        P                  ! 4       ^,          4      u Rp?# Rp?ii ; i)c           	      v   < \        V S4      w  ppppppS	P                  V4      P                  VVVVVVR 7      # r%  rJ  
r6  ru  r7  r8  r9  r:  r;  r<  r>  r   s
   &&      r   r?  6_StreamUnaryMultiCallable.future.<locals>.continuation;  sZ     ,K9LM";;z*11 #%+1+ 2  r   N)rM   r  r  r~  rf   ra   r4  r5  
r   ru  rZ   r[   r\   r]   r^   r?  rc   r>  s
   f&&&&&&  @r   rK   _StreamUnaryMultiCallable.future)  s     1LL
	$	A$$;;13C   	A"9cllnQ.?@@	ArP  c                R   < V ^8  d   Qh/ S[ ;R&   S[;R&   S[P                  ;R&   # rR  rn  )r   r   s   "r   r   rp    rh  r   rS  rT  rU  rH   s   @r   rl  rl    rV  r   rl  c                   T   a  ] tR tRt o V 3R lR ltR	V 3R lR lltV 3R ltRtV tR# )
_StreamStreamMultiCallableiU  c                @   < V ^8  d   QhRS[ RS[RS[P                  /# r  r   rR   r   StreamStreamClientInterceptor)r   r   s   "r   r   '_StreamStreamMultiCallable.__annotate__Z  s/     ( (( ( 77	(r   c                *    Wn         W n        W0n        R # r   r  r  s   &&&&r   r    #_StreamStreamMultiCallable.__init__Z  r  r   Nc                   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[P
                  ,          RS[S[,          RS[S[P                  ,          /# )r   ru  rZ   r[   r\   r]   r^   )r   r   rS   r   r   rT   rU   rV   )r   r   s   "r   r   r  d  sr     )A )A-)A %)A <(	)A
 d223)A !)A d../)Ar   c                   a a	 \        S P                  VVVVV4      o	V	V 3R  lp S P                  P                  VS	V4      #   \         d1   p\        T\        P                  ! 4       ^,          4      u Rp?# Rp?ii ; i)c           	      d   < \        V S4      w  ppppppS	P                  V4      ! VVVVVVR 7      # r%  rc  r  s
   &&      r   r?  9_StreamStreamMultiCallable.__call__.<locals>.continuationv  sO     ,K9LM";;z* #%+1+ r   N)rM   r  r  intercept_stream_streamrf   ra   r4  r5  r  s
   f&&&&&&  @r   r*  #_StreamStreamMultiCallable.__call__d  s     1LL
	$	A$$<<13C   	A"9cllnQ.?@@	ArP  c                R   < V ^8  d   Qh/ S[ ;R&   S[;R&   S[P                  ;R&   # rR  r  )r   r   s   "r   r   r  U  s-      L  444 r   rS  rT  ri  rH   s   @r   r  r  U  rj  r   r  c                      a  ] tR tRt o V 3R lR ltRV 3R lR lltV 3R lR ltRV 3R	 lR
 lltRV 3R lR lltRV 3R lR llt	RV 3R lR llt
R tR tR tR tV 3R ltRtV tR# )_Channeli  c                   < V ^8  d   QhRS[ P                  RS[S[ P                  S[ P                  S[ P
                  S[ P                  3,          /# )r   channelr8   r   Channelr   r  r[  r  ro  )r   r   s   "r   r   _Channel.__annotate__  sQ     ( (( ,,--..--/
(r   c                    Wn         W n        R # r   _channelr  )r   r  r8   s   &&&r   r    _Channel.__init__  s      'r   c                6   < V ^8  d   QhRS[ RS[S[,          /# )r   r   try_to_connect)r   r   rU   )r   r   s   "r   r   r    s%     I I I2:4.Ir   c                >    V P                   P                  WR 7       R# ))r  N)r  	subscribe)r   r   r  s   &&&r   r  _Channel.subscribe  s     	Hr   c                    < V ^8  d   QhRS[ /# )r   r   )r   )r   r   s   "r   r   r    s     , ,H ,r   c                <    V P                   P                  V4       R # r   )r  unsubscriber   s   &&r   r  _Channel.unsubscribe  s    !!(+r   Nc          
      |   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[,          RS[P                  /# r   rX   request_serializerresponse_deserializer_registered_methodr%   )rR   r   r   r   rU   r   UnaryUnaryMultiCallable)r   r   s   "r   r   r    sS       %%89  ((=>	
 %TN 
	%	%r   c                   a aaa VVVV 3R  lp\        S P                  \        P                  4      '       d   \	        WQS P                  4      # V! V4      # )c                 @   < SP                   P                  V SSS4      # r   )r  unary_unarymr  r  r  r   s   &r   r,   &_Channel.unary_unary.<locals>.<lambda>  s     $--33!	
r   )
isinstancer  r   r  r  r   rX   r  r  r  r#   s   f&fff r   r  _Channel.unary_unary  sB    
 d'')I)IJJ+E4;L;LMMV}r   c          
      |   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[,          RS[P                  /# r  )rR   r   r   r   rU   r   UnaryStreamMultiCallable)r   r   s   "r   r   r    S       %%89  ((=>	
 %TN 
	&	&r   c                   a aaa VVVV 3R  lp\        S P                  \        P                  4      '       d   \	        WQS P                  4      # V! V4      # )c                 @   < SP                   P                  V SSS4      # r   )r  unary_streamr  s   &r   r,   '_Channel.unary_stream.<locals>.<lambda>       $--44!	
r   )r  r  r   r[  rX  r  s   f&fff r   r  _Channel.unary_stream  B    
 d'')J)JKK,UD<M<MNNV}r   c          
      |   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[,          RS[P                  /# r  )rR   r   r   r   rU   r   StreamUnaryMultiCallable)r   r   s   "r   r   r    r  r   c                   a aaa VVVV 3R  lp\        S P                  \        P                  4      '       d   \	        WQS P                  4      # V! V4      # )c                 @   < SP                   P                  V SSS4      # r   )r  stream_unaryr  s   &r   r,   '_Channel.stream_unary.<locals>.<lambda>  r  r   )r  r  r   ro  rl  r  s   f&fff r   r  _Channel.stream_unary  r  r   c          
      |   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[,          RS[P                  /# r  )rR   r   r   r   rU   r   StreamStreamMultiCallable)r   r   s   "r   r   r    sS       %%89  ((=>	
 %TN 
	'	'r   c                   a aaa VVVV 3R  lp\        S P                  \        P                  4      '       d   \	        WQS P                  4      # V! V4      # )c                 @   < SP                   P                  V SSS4      # r   )r  stream_streamr  s   &r   r,   (_Channel.stream_stream.<locals>.<lambda>  s     $--55!	
r   )r  r  r   r  r  r  s   f&fff r   r  _Channel.stream_stream  sB    
 d'')K)KLL-eT=N=NOOV}r   c                :    V P                   P                  4        R # r   r  closert   s   &r   _close_Channel._close      r   c                    V # r   r.   rt   s   &r   	__enter___Channel.__enter__  r   r   c                &    V P                  4        R # r   )r  )r   exc_typeexc_valexc_tbs   &&&&r   __exit___Channel.__exit__  s    r   c                :    V P                   P                  4        R # r   r  rt   s   &r   r  _Channel.close  r  r   c                   < V ^8  d   Qh/ S[ P                  ;R&   S[S[ P                  S[ P                  S[ P
                  S[ P                  3,          ;R&   # )r   r  r  r  )r   r   s   "r   r   r    sO     ll (())**))	+  r   r  r   )NNF)rA   rB   rC   rD   r    r  r  r  r  r  r  r  r  r  r  rE   rF   rG   rH   s   @r   r  r    si     ( (I I
, , ( ( ( &q  r   r  c          
         V ^8  d   QhR\         P                  R\        \        \        \         P
                  \         P                  \         P                  \         P                  3,          ,          ,          R\         P                  /# )r   r  r   r%   )	r   r  r   r   r   r  r[  r  ro  )r   s   "r   r   r     sl      \\001122113	
	 
\\r   c                 l   \        \        V4      4       F  p\        V\        P                  4      '       gn   \        V\        P
                  4      '       gN   \        V\        P                  4      '       g.   \        V\        P                  4      '       g   R p\        V4      h\        W4      p K  	  V # )zinterceptor must be grpc.UnaryUnaryClientInterceptor or grpc.UnaryStreamClientInterceptor or grpc.StreamUnaryClientInterceptor or grpc.StreamStreamClientInterceptor)
reversedlistr  r   r  r[  ro  r  	TypeErrorr  )r  r   r8   	error_msgs   &*  r   intercept_channelr    s      \ 23;(H(HII{D,M,MNN{D,M,MNN{D,N,NOO5  I&&70 4  Nr   )rX   rZ   r[   r\   r]   r^   ))__doc__collectionsr4  rg   typingr   r   r   r   r   r   r   _typingr   r
   r   r   r   objectr   rK   
namedtuplerQ   rM   r_   r3  Futurer   ra   r   r  r  r  rX  r  rl  r  r  r  r  r  r.   r   r   <module>r     s   2  
  B B  * % ! ( (5v 50D		

 		"0OfCMM4;;		CL3DIIt{{ 3lLAt;; LA^8A = = 8AvLA = = LA^8A!?!? 8Avyt|| yxr   