hDSSKrSSKJr "SS\5r"SS\5rg)N) IBatchedTimerc*\rSrSrSrSrSrSrSrg) _BatchedCallz Wraps IDelayedCall-implementing objects, implementing only the API which txaio promised in the first place: .cancel Do not create these yourself; use _BatchedTimer.call_later() c(XlX lX0lgN)_timer_index_call)selftimerindexthe_calls QC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\txaio/_common.py__init___BatchedCall.__init__'s   c^URRURU5 SUlgr)r _remove_callr r s rcancel_BatchedCall.cancel-s!   d3 rc"UR5$r)r rs r__call___BatchedCall.__call__1szz|r)r r r N) __name__ __module__ __qualname____firstlineno____doc__rrr__static_attributes__rrrrs rrc6\rSrSrSrS SjrSrSrSrSr g) _BatchedTimer5a! Internal helper. Instances of this are returned from :meth:`txaio.make_batched_timer` and that is the only way they should be instantiated. You may depend on methods from the interface class only (:class:`txaio.IBatchedTimer`) **NOTE** that the times are in milliseconds in this class! NcUS::a [S5e[U5UlX lX0lX@l[ 5UlXPlg)Nz!bucket_milliseconds must be > 0.0) ValueErrorfloat_bucket_milliseconds _chunk_size _get_seconds_create_delayed_calldict_buckets_loop)r bucket_milliseconds chunk_sizeseconds_providerdelayed_call_creatorloops rr_BatchedTimer.__init__AsF # %@A A$)*=$>!%,$8!  rc^^^UR5n[XQ-5S-nU[X`R-5-n[XUUU4Sj5nURUSR U5 U$![ aD US- U- nUR[SU5URU5n X/4URU'U$f=f)z IBatchedTimer API ic>T"T0TD6$rr")argsfunckwargssr*_BatchedTimer.call_later..ZsT45J65Jr@@r') r,intr*rr/appendKeyErrorr-max_notify_bucket) r delayr:r9r;now real_timecalldiff delayed_calls ``` r call_later_BatchedTimer.call_laterRs ! $t+ S%>%>>?? D-JK > MM) $Q ' . .t 4  >&#-D 44C##L )5f'=DMM) $  >s!A44A CCc^^^TRUup#TRU /mUUU4SjmTR[R"[ [ U55TR - 5- nT"UTR [SU55 g)zu Internal helper. This 'does' the callbacks in a particular bucket. :param real_time: the bucket to do callbacks on c<>USUH nU"5 M XSnU(aTRUS- TUUU5 g[T5(a*SnTHnUSR U5- nM [ U5eg![anTRU5 SnAMSnAff=f)Nr?z'Error(s) processing call_later bucket: z{} ) ExceptionrAr-lenformat RuntimeError) callsr2chunk_delay_msrHemsgerrorsnotify_one_chunkr s rrX6_BatchedTimer._notify_bucket..notify_one_chunkuskz*%F+ +&E))"V+$" v;;DC#v}}Q//$&s++ !%MM!$$%sA55 B?BBr'N)r/r*mathceilr)rPr+rC)r rGrJrSdelay_msrWrXs` @@rrD_BatchedTimer._notify_bucketks{ !% i 8 MM) $ ,2,,tyy #e*  0 0 00    0 0#c82DErcURUup4URU5 U(dURU UR5 gg![a gf=f)z Internal helper. Removes a (possibly still pending) call from a bucket. It is *not* an error of the bucket is gone (e.g. the call has already happened). N)r/rBremover)r rGrHrJrSs rr_BatchedTimer._remove_callsZ  $(MM)$< !\  T i(    !    sA AA)r*r/r+r-r,r0r) rrrrr rrKrDrr!r"rrr$r$5s" " "2(FT"rr$)rZtxaio.interfacesrobjectrr$r"rrrcs'6 *6,p"Mp"r