+
     BiA                        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                     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                   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
_callbacks	get_debugr   extract_stacksys	_getframe_source_tracebackselfr	   s   &$&/usr/lib/python3.14/asyncio/futures.py__init__Future.__init__K   s\     <..0DJJ::!!%3%A%Aa &"D" "    c                .    \         P                  ! V 4      # r   )r   _future_reprr   s   &r   __repr__Future.__repr__[   s    ((..r   c                    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 # )Nmessagez exception was never retrieved	exceptionfuturesource_traceback)_Future__log_traceback
_exception	__class____name__r   r   call_exception_handler)r   exccontexts   &  r   __del__Future.__del__^   sw    ### oo>>**++IJd	
 !!!*.*@*@G&'

))'2r   c                    V P                   # r   )r$   r   s   &r   _log_tracebackFuture._log_tracebackp   s    ###r   c                :    V'       d   \        R 4      hRV n        R# )z'_log_traceback can only be set to FalseFN)
ValueErrorr$   )r   vals   &&r   r.   r/   t   s    FGG$r   c                L    V P                   f   R # \        V P                   4      # r   )_Future__asyncio_awaited_by	frozensetr   s   &r   _asyncio_awaited_byFuture._asyncio_awaited_byz   s"    $$,2233r   c                <    V P                   pVf   \        R4      hV# )Nz!Future object is not initialized.)r   RuntimeErrorr   s   & r   get_loopFuture.get_loop   s!    zz<BCCr   c                    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)   s   & r   _make_cancelled_errorFuture._make_cancelled_error   sf     *%%C"&DJ'++-C 
 ++D,@,@AC
r   c                    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   msgs   &&r   cancelFuture.cancel   s7      %;;(" "!!#r   c                    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   	callbackscallbackctxs   &   r   __schedule_callbacksFuture.__schedule_callbacks   sI     OOA&	&MHJJ   = 'r   c                (    V P                   \        8H  # r   )rC   rE   r   s   &r   	cancelledFuture.cancelled   s    {{j((r   c                (    V P                   \        8g  # r   )rC   rD   r   s   &r   doneFuture.done   s     {{h&&r   c                .   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)rC   rE   r@   	_FINISHEDr   InvalidStateErrorr$   r%   with_traceback_exception_tb_resultr   s   &r   resultFuture.result   st     ;;*$,,..;;)#../EFF$??&//001C1CDD||r   c                    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)rC   rE   r@   rZ   r   r[   r$   r%   r   s   &r   r!   Future.exception   sO     ;;*$,,..;;)#../FGG$r   r*   c                   V P                   \        8w  d    V P                  P                  WVR 7       R# Vf   \        P
                  ! 4       pV P                  P                  W34       R# )rL   N)rC   rD   r   rM   contextvarscopy_contextr   append)r   fnr*   s   &&$r   add_done_callbackFuture.add_done_callback   sN     ;;("JJ  7 ;%224OO""B=1r   c                    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 )rK   )r   len)r   rg   frP   filtered_callbacksremoved_counts   &&    r   remove_done_callbackFuture.remove_done_callback   sh     /3oo*.=(1!" 'qh.= 	 * DOO,s3E/FF!3OOA*s
   
A&A&c                    V P                   \        8w  d'   \        P                  ! V P                    R V : 24      hWn        \
        V n         V P                  4        R# ): N)rC   rD   r   r[   r^   rZ   rF   )r   r_   s   &&r   
set_resultFuture.set_result  sH     ;;("..$++b/IJJ!!#r   c                   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# )rr   zPStopIteration interacts badly with generators and cannot be raised into a FutureTN)rC   rD   r   r[   
isinstancetypeStopIterationr9   	__cause____context__r%   __traceback__r]   rZ   rF   r$   )r   r!   new_excs   && r   set_exceptionFuture.set_exception  s     ;;("..$++b/IJJi&&!Ii//" $, -G !*"+I#&44!!##r   c              #     "   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)rW   _asyncio_future_blockingr9   r_   r   s   &r   	__await__Future.__await__$  s@     yy{{,0D)Jyy{{>??{{}s
   7AA)__log_tracebackr   r   r>   r=   r%   r]   r   r^   r   rC   r   ))r'   
__module____qualname____firstlineno__rD   rC   r^   r%   r   r   r>   r=   r   r4   r$   r   r   r+   classmethodr   __class_getitem__propertyr.   setterr6   r:   r@   rH   rF   rT   rW   r_   r!   rh   ro   rs   r}   r   __iter____static_attributes____classdictcell__)__classdict__s   @r   r   r      s     & FGJEON  %  O"t " /3  $L1$ $ % %
 4 4
">)' 2t 2 
$$. Hr   c                 b     V P                   pV! 4       #   \         d     T P                  # i ; ir   )r:   AttributeErrorr   )futr:   s   & r   	_get_loopr   3  s:    << z   99	s    ..c                 X    V P                  4       '       d   R # V P                  V4       R # r   )rT   rs   )r   r_   s   &&r   _set_result_unless_cancelledr   ?  s    
}}NN6r   c                 p   \        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   )	rw   
concurrentfuturesr?   r   argsr\   r{   r[   )r)   	exc_classs   & r   _convert_future_excr   F  s    S	IJ&&555((#((3BB3CTCTUU	j((::	:++SXX6EEcFWFWXX
r   c                 ,   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   )rT   rH   set_running_or_notify_cancelr!   r}   r   r_   rs   )r   sourcer!   r_   s   &&  r   _set_concurrent_future_stater   P  sr     2244  "I  !4Y!?@f%r   c                 (   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   )rT   rH   r!   r}   r   r_   rs   )r   destr!   r_   s   &&  r   _copy_future_stater   _  sk     ~~$$&	 29=>]]_FOOF#r   c                   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 V3R lpV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                 X    \        V 4      '       d   \        W4       R # \        W4       R # r   )isfuturer   r   )r"   others   &&r   
_set_state!_chain_future.<locals>._set_state  s    Fu-(7r   c                    < V P                  4       '       d:   Se   SSJ d   SP                  4        R # SP                  SP                  4       R # R # r   )rT   rH   call_soon_threadsafe)destination	dest_loopr   source_loops   &r   _call_check_cancel)_chain_future.<locals>._call_check_cancel  s?      """kY&>00?	 #r   c                    < SP                  4       '       d   Se   SP                  4       '       d   R # Se   SSJ d   S! SV 4       R # SP                  4       '       d   R # SP                  SSV 4       R # r   )rT   	is_closedr   )r   r   r   r   r   s   &r   _call_set_state&_chain_future.<locals>._call_set_state  sd    !!##%)*=*=*?*?	[ 8{F+""$$**:{FKr   )r   rv   r   r   r   	TypeErrorr   rh   )r   r   r   r   r   r   r   s   ff  @@@r   _chain_futurer   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 	L !!"45
_-r   r	   c                    \        V 4      '       d   V # Vf   \        P                  ! 4       pVP                  4       p\	        W4       V# r   )r   r   r   create_futurer   )r"   r	   
new_futures   &$ r   wrap_futurer     sC     |$$&##%J&%r   c                    \        V \        4      '       dS   \        V\        4      '       d;   V P                  f   \        4       V n        V P                  P	                  V4       R # R # R # r   )rv   	_PyFuturer4   setaddr   waiters   ""r   future_add_to_awaited_byr     sP    , #y!!j&C&C**2.1eC+''++F3 'D!r   c                    \        V \        4      '       dF   \        V\        4      '       d.   V P                  e   V P                  P                  V4       R # R # R # R # r   )rv   r   r4   discardr   s   ""r   future_discard_from_awaited_byr     sK     #y!!j&C&C**6++33F; 7 'D!r   )r   r   r   r   r   )%__all__concurrent.futuresr   rd   loggingr   typesr    r   r   r   r   r   rD   rE   rZ   DEBUGSTACK_DEBUGr   r   r   r   r   r   r   r   r   r   r   _py_future_add_to_awaited_by"_py_future_discard_from_awaited_by_asyncio_CFuture_c_future_add_to_awaited_by!_c_future_discard_from_awaited_byImportError r   r   <module>r      s  
    
           $$
""	 mmaM Mb 		&$().X
 
48	<  8 %C "
G
 !'FX'@@%-%L%L"":(F%  		s   $C CC