🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:27:28 | 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: _throttlefirst.cpython-38.pyc
Read Only
U v�i_ � @ s� d dl m Z d dlmZmZmZ d dlmZmZmZ d dlm Z ed�Z d ej eej eee gee f d�dd �Z d gZdS ) � )�datetime)�Callable�Optional�TypeVar)� Observable�abc�typing)�TimeoutScheduler�_TN)�window_duration� scheduler�returnc s" t t t t d�� �fdd� }|S )N)�sourcer c s2 dt jt tt j t jd��� �fdd� }t|�S )a: Returns an observable that emits only the first item emitted by the source Observable during sequential time windows of a specified duration. Args: source: Source observable to throttle. Returns: An Observable that performs the throttle operation. N)�observer� scheduler_r c sj �p|pt �� � � ��pd���� �d�kr4td��d �td d�� ����fdd� }�j|�j�j� d�S )Ng r z-window_duration cannot be less or equal zero.)�xr c sF d}� j }�j� �r"|� �kr*|�d}W 5 Q R X |rB��| � d S )NFT)�now�lock�on_next)r �emitr )� _scheduler�duration� last_on_nextr r � �S/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_throttlefirst.pyr $ s zKthrottle_first_.<locals>.throttle_first.<locals>.subscribe.<locals>.on_next)r )r Z singletonZ to_timedelta� ValueErrorr � subscribeZon_errorZ on_completed)r r r )r r r )r r r r r r s �z:throttle_first_.<locals>.throttle_first.<locals>.subscribe)N)r Z ObserverBaser r � SchedulerBaseZDisposableBaser )r r �r r )r r �throttle_first s ��z'throttle_first_.<locals>.throttle_first)r r )r r r r r r �throttle_first_ s )r )N)r r r r r Z reactivexr r Zreactivex.schedulerr r Z RelativeTimer r �__all__r r r r �<module> s � � /
💾 Save Changes
❌ Cancel