
    E#i                     6    S SK r  " S S\ R                  5      rg)    Nc                   8    \ rS rSrSS jrSS jr\S 5       rSrg)Future   Nc                 R    U R                  5       (       d  U R                  U5        g g N)done
set_result)selfresults     [/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/async_support/base/ws/future.pyresolveFuture.resolve   s    yy{{OOF#     c                 R    U R                  5       (       d  U R                  U5        g g r   )r   set_exception)r
   errors     r   rejectFuture.reject   s     yy{{u% r   c                    ^ [        5       m[        R                  " U[        R                  S9n[        R                  " U5      nU4S jnUR                  U5        T$ )N)return_whenc                   > U R                  5       u  p/ nSnU HF  nUR                  5       (       a  SnM  UR                  5       nU(       d  M5  UR                  U5        MH     TR                  5       (       a  g [	        U5      S:  a  TR                  US   5        g U(       a  TR                  5         g [        U5      S   R                  5       nTR                  U5        g )NFTr   )	r   	cancelled	exceptionappendlenr   cancellistr	   )	r   complete_
exceptionsr   ferrfirst_resultfutures	           r   callbackFuture.race.<locals>.callback   s    ++-KHJI;;== $I++-Cs"))#.  !!:"$$Z]3#H~a0779!!,/r   )r   asynciowaitFIRST_COMPLETEDcreate_taskadd_done_callback)clsfuturescorotaskr%   r$   s        @r   raceFuture.race   sJ    ||G1H1HI""4(	0. 	x(r    r   )	__name__
__module____qualname____firstlineno__r   r   classmethodr0   __static_attributes__r2   r   r   r   r      s     $&  r   r   )r'   r   r2   r   r   <module>r9      s    
(W^^ (r   