g\ddlZddlZddlmZmZej eZGddZy)N)CallableOptionalc@eZdZdedeegeffdZdZdZdefdZ y) AsyncTimercallback timer_calcc<||_||_d|_d|_y)Nr)rrtimertries)selfrrs J/var/www/openai/venv/lib/python3.12/site-packages/realtime/_async/timer.py__init__zAsyncTimer.__init__ s  $-1  cd|_|jrR|jjs7|jjd|_tj dyyy)NrzEAsyncTimer has been reset and any scheduler tasks have been cancelled)r r donecancelloggerdebug)r s r resetzAsyncTimer.resetsJ ::djjoo/ JJ   DJ LLW 0:rc:|jr|jj|xjdz c_|j|jdz}tj d|dt j|j||_y)Nz!Scheduling callback to run after z seconds.) r rr rrrasyncio create_task _run_timer)r delays r schedule_timeoutzAsyncTimer.schedule_timeoutsm :: JJ    a  Q/ 8yIJ(()?@ rrc.K tj|d{|jd{y77#tj$rtj dYyt $r"}tjd|Yd}~yd}~wwxYww)NzAsyncTimer task was cancelled.zError in AsyncTimer callback: )rsleeprCancelledErrorrr Exception exception)r res r rzAsyncTimer._run_timer!s{ C--& & &--/ ! ! ' !%% ; LL9 : C   =aSA B B CsOB>:><>B>>(B&B(B0B B BBN) __name__ __module__ __qualname__rintrrrfloatrrr rrs9xs 7K ACeCrr) rloggingtypingrr getLoggerr#rrr(rr r,s,%   8 $ C Cr