
    H>qj                          d dl Z d dlZd dlmZ  e ed            Z e edd            Z e j                         j                         Z
 G d dej                        Zy)    N)Event
   d   n   c                       e Zd Zd Zd Zd Zy)
CreateTestc                     t        j                  t              }t        j                  d|j                  d       t        j                  |      }| j                  |j                         dg       y )N)loopMbP?*   )	asyncioFuturer
   
call_later
set_resultr   waitassertEqualrun)selffutevents      P/opt/rentech/trading_bot/.venv/lib/python3.12/site-packages/tests/create_test.py	test_waitzCreateTest.test_wait   sI    nn$'s~~r2

3rd+    c                     d }t        j                   |             }| j                  |j                         t               y )Nc                 j   K   t        j                  d       d {    t        D ]  } |  	 y 7 w)Nr   )r   sleeparray1)is    r   aitz%CreateTest.test_aiterate.<locals>.ait   s1     --"""  #s   313)r   aiterater   r   r   )r   r   r   s      r   test_aiteratezCreateTest.test_aiterate   s/    	 su%f-r   c                     d}t        j                  |d      }| j                  |j                         dD cg c]  }| c}       y c c}w )Nz   a b c   d e fr   )intervalabcdef)r   marbler   r   )r   sr   cs       r   test_marblezCreateTest.test_marble   s;    Q/(&;Qq&;<&;s   	A	
N)__name__
__module____qualname__r   r!   r(    r   r   r   r      s    ,.=r   r   )r   unittesteventkitr   listranger   array2get_event_loop_policyget_event_loopr
   TestCaser   r,   r   r   <module>r5      sV      	eBi	eCo	$w$$&557="" =r   