🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:30:08 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/__pycache__
🔄 Refresh
✏️
Editing: _timestamp.cpython-38.pyc
Read Only
U v�iC � @ s� d dl mZ d dlmZ d dlmZmZmZmZ d dlm Z m Z m Z m Z d dl mZ ed�ZeG dd� dee ��Zd ee j ee e ge ee f d �d d �Zd gZd S )� )� dataclass)�datetime)�Callable�Generic�Optional�TypeVar)� Observable�abc�defer� operators)�TimeoutScheduler�_Tc @ s e Zd ZU eed< eed< dS )� Timestamp�value� 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)� scheduler�returnc 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 | � jd�S )N)r r )r �now)r �Z _schedulerr r �mapper' s z>timestamp_.<locals>.timestamp.<locals>.factory.<locals>.mapper)r Z singletonr r �piper �map)r r )r r r r �factory$ s z.timestamp_.<locals>.timestamp.<locals>.factory)N)r r � SchedulerBaser )r r �r )r r r s z timestamp_.<locals>.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 �<module> s ��
💾 Save Changes
❌ Cancel