U
viC @ s d dl mZ d dlmZ d dlmZmZmZmZ d dlm Z m
Z
m Z m Z d dl
mZ edZeG dd dee Zd
ee
j ee e ge ee f d
d d Zd gZd S ) ) dataclass)datetime)CallableGenericOptionalTypeVar)
Observableabcdefer operators)TimeoutScheduler_Tc @ s e Zd ZU eed< eed< dS ) Timestampvalue timestampN)__name__
__module__ __qualname__r
__annotations__r r r O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_timestamp.pyr s
r N) schedulerreturnc s$ t t t tt d fdd }|S )N)sourcer c s$ dt tj d fdd
}t|S )a Records the timestamp for each value in an observable sequence.
Examples:
>>> timestamp(source)
Produces objects with attributes `value` and `timestamp`, where
value is the original value.
Args:
source: Observable source to timestamp.
Returns:
An observable sequence with timestamp information on values.
N)
scheduler_c s8 p| pt ttt d fdd }t|S )N)r r c s t | jdS )N)r r )r now)r Z
_schedulerr r mapper' s z>timestamp_..timestamp..factory..mapper)r Z singletonr
r piper map)r r )r r r r factory$ s z.timestamp_..timestamp..factory)N)r r
SchedulerBaser
)r r r )r r r s z timestamp_..timestamp)r r
r )r r r r" r
timestamp_ s r# )N) dataclassesr r typingr r r r Z reactivexr r r
r Zreactivex.schedulerr r
r r! r# __all__r r r r s