🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 12:41:49 | 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: _timeinterval.cpython-38.pyc
Read Only
U v�i � @ s� d dl mZ d dlmZ d dlmZmZmZmZ d dl m Z m Z d dl m Z d dlmZ ed�ZeG dd � d ee ��Zdee j ee e ge ee f d �d d �Zd S )� )� dataclass)� timedelta)�Callable�Generic�Optional�TypeVar)� Observable�abc)� operators)�TimeoutScheduler�_Tc @ s e Zd ZU eed< eed< dS )� TimeInterval�value�intervalN)�__name__� __module__� __qualname__r �__annotations__r � r r �R/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_timeinterval.pyr s r N)� scheduler�returnc s$ t t t tt d�� fdd� }|S )N)�sourcer c s4 dt jtt tt j t jd��� fdd� }t|�S )z�Records 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 �� � � j�ttt d�� �fdd� }��t�|��j| � d�S )N)r r c s � j }|� }|�t| |d�S )N)r r )�nowr )r r �span�Z _scheduler�lastr r �mapper' s zHtime_interval_.<locals>.time_interval.<locals>.subscribe.<locals>.mapper�r ) r Z singletonr r r �pipe�ops�map� subscribe)r r r )r r r r r$ s �z8time_interval_.<locals>.time_interval.<locals>.subscribe)N)r Z ObserverBaser r r � SchedulerBaseZDisposableBaser )r r$ r )r r � time_interval s � �z%time_interval_.<locals>.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 �<module> s ��
💾 Save Changes
❌ Cancel