+
    iA  c                   s   Rt ^ RIt^ RIt^ RIt^ RIt^ RIHt ^RIH	t	 ^RIH
t
 ^RIHt ^RIHt ]	P                  t]	P                  t]	P                  t]	P                   t]P"                  ^,
          t ! R R 4      t]tR tR	 tR
 tR tR tR tRR/R ltR tR t]t]t ^ RI t ] P&                  ;tt!] P8                  t] P:                  t]t"]t#R#   ]$ d     R# i ; i)FutureN)GenericAlias)base_futures)events)
exceptions)format_helpersc                   s  a  ] tR t^t o ]tRtRtRtRt	Rt
RtRtRtRtRR/R ltR tR t]! ]4      t]R 4       t]P.                  R 4       t]R	 4       tR
 tR tRR ltR tR tR tR tR t RR/R lt!R t"R t#R t$R t%]%t&Rt'V t(R# )r    NFloopc               s    Vf   \         P                  ! 4       V n        MWn        . V n        V P                  P	                  4       '       d2   \
        P                  ! \        P                  ! ^4      4      V n	        R # R # N)
r   get_event_loop_loop
_callbacksZ	get_debugr   Zextract_stacksysZ	_getframe_source_tracebackselfr   s   &$(/usr/lib64/python3.14/asyncio/futures.py__init__ZFuture.__init__K   s\     <..0DJJ::!!%3%A%Aa &"D" "    c                s.    \         P                  ! V 4      # r   )r   Z_future_reprr      &r   __repr__ZFuture.__repr__[   s    ((..r   c                s    V P                   '       g   R # V P                  pRV P                  P                   R2RVRV /pV P                  '       d   V P                  VR&   V P
                  P                  V4       R # )NZmessagez exception was never retrieved	exceptionfutureZsource_traceback)_Future__log_traceback
_exceptionZ	__class____name__r   r	   Zcall_exception_handler)r   exccontexts   &  r   __del__ZFuture.__del__^   sw    ### oo>>**++IJd	
 !!!*.*@*@G&'

))'2r   c                s    V P                   # r   )r   r   r   r   _log_tracebackFuture._log_tracebackp   s    ###r   c                s:    V'       d   \        R 4      hRV n        R# )z'_log_traceback can only be set to FalseFN)Z
ValueErrorr   )r   Zval   &&r   r   r   t   s    FGG$r   c                sL    V P                   f   R # \        V P                   4      # r   )_Future__asyncio_awaited_byZ	frozensetr   r   r   _asyncio_awaited_byZFuture._asyncio_awaited_byz   s"    $$,2233r   c                s<    V P                   pVf   \        R4      hV# )Nz!Future object is not initialized.)r	   RuntimeErrorr      & r   get_loopZFuture.get_loop   s!    zz<BCCr   c                s    V P                   e   V P                   pR V n         V# V P                  f   \        P                  ! 4       pV# \        P                  ! V P                  4      pV# r   )_cancelled_exc_cancel_messager   CancelledError)r   r   r#   r   _make_cancelled_errorZFuture._make_cancelled_error   sf     *%%C"&DJ'++-C 
 ++D,@,@AC
r   c                s    R V n         V P                  \        8w  d   R # \        V n        Wn        V P                  4        R# )FT)r   _state_PENDING
_CANCELLEDr&   _Future__schedule_callbacks)r   Zmsgr   r   cancelZFuture.cancel   s7      %;;(" "!!#r   c                s    V P                   R ,          pV'       g   R# . V P                   R &   V F"  w  r#V P                  P                  W VR7       K$  	  R# )NNNNr   )r
   r	   	call_soon)r   Z	callbacksZcallbackctxs   &   r   Z__schedule_callbacksZFuture.__schedule_callbacks   sI     OOA&	&MHJJ   = 'r   c                s(    V P                   \        8H  # r   )r)   r+   r   r   r   	cancelledZFuture.cancelled   s    {{j((r   c                s(    V P                   \        8g  # r   )r)   r*   r   r   r   doneZFuture.done   s     {{h&&r   c                s.   V P                   \        8X  d   V P                  4       hV P                   \        8w  d   \        P
                  ! R 4      hRV n        V P                  e&   V P                  P                  V P                  4      hV P                  # )zResult is not ready.F)r)   r+   r(   	_FINISHEDr   InvalidStateErrorr   r   with_traceback_exception_tb_resultr   r   r   resultZFuture.result   st     ;;*$,,..;;)#../EFF$??&//001C1CDD||r   c                s    V P                   \        8X  d   V P                  4       hV P                   \        8w  d   \        P
                  ! R 4      hRV n        V P                  # )zException is not set.F)r)   r+   r(   r4   r   r5   r   r   r   r   r   r   ZFuture.exception   sO     ;;*$,,..;;)#../FGG$r   r   c               s    V P                   \        8w  d    V P                  P                  WVR 7       R# Vf   \        P
                  ! 4       pV P                  P                  W34       R# )r/   N)r)   r*   r	   r0   contextvarsZcopy_contextr
   Zappend)r   fnr   s   &&$r   add_done_callbackZFuture.add_done_callback   sN     ;;("JJ  7 ;%224OO""B=1r   c                s    V P                    UUu. uF  w  r#W!8w  g   K  W#3NK  	  ppp\        V P                   4      \        V4      ,
          pV'       d   W@P                   R &   V# u uppi )r.   )r
   Zlen)r   r;   Zfr1   Zfiltered_callbacksZremoved_counts   &&    r   remove_done_callbackZFuture.remove_done_callback   sh     /3oo*.=(1!" 'qh.= 	 * DOO,s3E/FF!3OOA*s
   
A&A&c                s    V P                   \        8w  d'   \        P                  ! V P                    R V : 24      hWn        \
        V n         V P                  4        R# ): N)r)   r*   r   r5   r8   r4   r,   )r   r9   r   r   
set_resultZFuture.set_result  sH     ;;("..$++b/IJJ!!#r   c                s   V P                   \        8w  d'   \        P                  ! V P                    R V : 24      h\	        V\
        4      '       d   V! 4       p\	        V\        4      '       d   \        R4      pWn        Wn	        TpWn
        VP                  V n        \        V n         V P                  4        RV n        R# )r>   zPStopIteration interacts badly with generators and cannot be raised into a FutureTN)r)   r*   r   r5   
isinstancetypeZStopIterationr"   Z	__cause__Z__context__r   __traceback__r7   r4   r,   r   )r   r   Znew_excs   && r   set_exceptionZFuture.set_exception  s     ;;("..$++b/IJJi&&!Ii//" $, -G !*"+I#&44!!##r   c              #  s   "   V P                  4       '       g   R V n        V x  V P                  4       '       g   \        R4      hV P                  4       # 5i)Tzawait wasn't used with future)r3   _asyncio_future_blockingr"   r9   r   r   r   	__await__ZFuture.__await__$  s@     yy{{,0D)Jyy{{>??{{}s
   7AA)Z__log_tracebackrD   r
   r&   r%   r   r7   r	   r8   r   r)   r   ))r   Z
__module__Z__qualname__Z__firstlineno__r*   r)   r8   r   r	   r   r&   r%   rD   r    r   r   r   r   Zclassmethodr   Z__class_getitem__Zpropertyr   Zsetterr!   r$   r(   r-   r,   r2   r3   r9   r   r<   r=   r?   rC   rE   Z__iter__Z__static_attributes__Z__classdictcell__)Z__classdict__s   @r   r    r       s     & FGJEON  %  O"t " /3  $L1$ $ % %
 4 4
">)' 2t 2 
$$. Hr   c                 sb     V P                   pV! 4       #   \         d     T P                  # i ; ir   )r$   ZAttributeErrorr	   )futr$   r#   r   	_get_looprG   3  s:    << z   99	s    ..c                 sX    V P                  4       '       d   R # V P                  V4       R # r   )r2   r?   )rF   r9   r   r   _set_result_unless_cancelledrH   ?  s    
}}NN6r   c                 sp   \        V 4      pV\        P                  P                  J d8   \        P                  ! V P
                  !  P                  V P                  4      # V\        P                  P                  J d8   \        P                  ! V P
                  !  P                  V P                  4      # V # r   )	rA   
concurrentfuturesr'   r   Zargsr6   rB   r5   )r   Z	exc_classr#   r   _convert_future_excrK   F  s    S	IJ&&555((#((3BB3CTCTUU	j((::	:++SXX6EEcFWFWXX
r   c                 s,   VP                  4       '       d   V P                  ! 4        V P                  ! 4       '       g   R # VP                  4       pVe   V P                  ! \        V4      4       R # VP                  4       pV P                  ! V4       R # r   )r2   r-   Zset_running_or_notify_cancelr   rC   rK   r9   r?   )rI   sourcer   r9      &&  r   _set_concurrent_future_staterN   P  sr     2244  "I  !4Y!?@f%r   c                 s(   VP                  4       '       d   R # V P                  4       '       d   VP                  4        R # V P                  4       pVe   VP                  \	        V4      4       R # V P                  4       pVP                  V4       R # r   )r2   r-   r   rC   rK   r9   r?   )rL   Zdestr   r9   rM   r   _copy_future_staterO   _  sk     ~~$$&	 29=>]]_FOOF#r   c                 s  a aaaa \        S 4      '       g6   \        S \        P                  P                  4      '       g   \        R 4      h\        S4      '       g6   \        S\        P                  P                  4      '       g   \        R4      h\        S 4      '       d   \        S 4      MRo\        S4      '       d   \        S4      MRoR oV V3R lpVVV3R lpSP                  V4       S P                  V4       R# )z(A future is required for source argumentz-A future is required for destination argumentNc                 sX    \        V 4      '       d   \        W4       R # \        W4       R # r   )isfuturerO   rN   )r   Zotherr   r   
_set_stateZ!_chain_future.<locals>._set_state  s    Fu-(7r   c                 s   < V P                  4       '       dM   Se   S\        P                  ! 4       J d   SP                  4        R # SP	                  SP                  4       R # R # r   )r2   r   _get_running_loopr-   call_soon_threadsafe)destinationrL   source_loops   &r   _call_check_cancelZ)_chain_future.<locals>._call_check_cancel  sH      """kV5M5M5O&O00?	 #r   c                 s  < SP                  4       '       d   Se   SP                  4       '       d   R # Se   S\        P                  ! 4       J d   S! SV 4       R # SP                  4       '       d   R # SP	                  SSV 4       R # r   )r2   Z	is_closedr   rR   rS   )rL   rQ   	dest_looprT   s   &r   _call_set_stateZ&_chain_future.<locals>._call_set_state  sm    !!##%)*=*=*?*?	V-E-E-G G{F+""$$**:{FKr   )rP   r@   rI   rJ   r    Z	TypeErrorrG   r<   )rL   rT   rV   rX   rQ   rW   rU   s   ff  @@@r   _chain_futurerY   s  s     FJv/9/A/A/H/H%J %JBCCK  K4>4F4F4M4M*O *OGHH'/'7'7)F#TK*2;*?*?	+&TI8@	L !!"45
_-r   r   c                s    \        V 4      '       d   V # Vf   \        P                  ! 4       pVP                  4       p\	        W4       V# r   )rP   r   r   Zcreate_futurerY   )r   r   Z
new_futures   &$ r   wrap_futurerZ     sC     |$$&##%J&%r   c                s    \        V \        4      '       dS   \        V\        4      '       d;   V P                  f   \        4       V n        V P                  P	                  V4       R # R # R # r   )r@   	_PyFuturer    ZsetZaddrF   Zwaiter   ""r   future_add_to_awaited_byr^     sP    , #y!!j&C&C**2.1eC+''++F3 'D!r   c                s    \        V \        4      '       dF   \        V\        4      '       d.   V P                  e   V P                  P                  V4       R # R # R # R # r   )r@   r[   r    Zdiscardr\   r]   r   future_discard_from_awaited_byr_     sK     #y!!j&C&C**6++33F; 7 'D!r   )r    rZ   rP   r^   r_   )%Z__all__Zconcurrent.futuresrI   r:   Zloggingr   Ztypesr   Z r   r   r   r   rP   r*   r+   r4   ZDEBUGZSTACK_DEBUGr    r[   rG   rH   rK   rN   rO   rY   rZ   r^   r_   Z_py_future_add_to_awaited_byZ"_py_future_discard_from_awaited_byZ_asyncioZ_CFutureZ_c_future_add_to_awaited_byZ!_c_future_discard_from_awaited_byZImportError) r   r   <module>r`      s  
    
           $$
""	 mmaM Mb 		&$().X
 
48	<  8 %C "
G
 !'FX'@@%-%L%L"":(F%  		s   $C CC