U
vi @ s d dl mZ d dlmZ d dlmZmZmZmZ d dl m
Z
m Z d dl m Z
d dlmZ edZeG dd d ee Zdee j ee
e ge
ee f d d d
Zd
S ) ) dataclass) timedelta)CallableGenericOptionalTypeVar)
Observableabc) operators)TimeoutScheduler_Tc @ s e Zd ZU eed< eed< dS ) TimeIntervalvalueintervalN)__name__
__module__ __qualname__r __annotations__r r r R/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_timeinterval.pyr
s
r
N) schedulerreturnc s$ t t t tt d fdd }|S )N)sourcer c s4 dt jtt tt j t jd fdd
}t|S )zRecords the time interval between consecutive values in an
observable sequence.
>>> res = time_interval(source)
Return:
An observable sequence with time interval information on
values.
N)observer
scheduler_r c sJ p|pt jttt d fdd }t|j| dS )N)r r c s j }| }|t| |dS )N)r r )nowr
)r r spanZ
_schedulerlastr r mapper' s zHtime_interval_..time_interval..subscribe..mapperr ) r Z singletonr r r
pipeopsmap subscribe)r r r )r r r r r$ s z8time_interval_..time_interval..subscribe)N)r Z ObserverBaser
r r
SchedulerBaseZDisposableBaser )r r$ r )r r
time_interval s
z%time_interval_..time_interval)r r r
)r r& r r r time_interval_ s r' )N) dataclassesr datetimer typingr r r r Z reactivexr r r
r" Zreactivex.schedulerr r r
r% r' r r r r s