🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 11:43:17 | 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: _skiplastwithtime.cpython-38.pyc
Read Only
U v�i0 � @ s� d dl mZmZmZmZmZmZ d dlmZm Z m Z d dl m Z ed�Z d e j ee j eee gee f d�dd�ZdgZdS ) � )�Any�Callable�Dict�List�Optional�TypeVar)� Observable�abc�typing)�TimeoutScheduler�_TN)�duration� scheduler�returnc s" t t t t d�� �fdd� }|S )a Skips elements for the specified duration from the end of the observable source sequence. Example: >>> res = skip_last_with_time(5.0) This operator accumulates a queue with a length enough to store elements received during the initial duration window. As more elements are received, elements older than the specified duration are taken from the queue and produced on the result sequence. This causes elements to be delayed with duration. Args: duration: Duration for skipping elements from the end of the sequence. scheduler: Scheduler to use for time handling. Returns: An observable sequence with the elements skipped during the specified duration from the end of the source sequence. )�sourcer c s2 dt jt tt j t jd���� fdd� }t|�S )N)�observer� scheduler_r c sd �p|pt �� � � ����g �td d�� ���fdd� }d d�� ���fdd� }�j|�j|� d�S )N)�xr c sH � j }��|| d�� �rD|�d d �krD����d�d � qd S )N)�interval�valuer r r )�now�append�on_next�pop)r r �� _schedulerr r �q� �V/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_skiplastwithtime.pyr / s zUskip_last_with_time_.<locals>.skip_last_with_time.<locals>.subscribe.<locals>.on_next)r c s@ � j } �r4| �d d �kr4����d�d � q��� d S )Nr r r )r r r � on_completed)r r r r r 5 s zZskip_last_with_time_.<locals>.skip_last_with_time.<locals>.subscribe.<locals>.on_completed)r )r Z singletonZ to_timedeltar � subscribeZon_error)r r r r )r r r )r r r r r # s � �zDskip_last_with_time_.<locals>.skip_last_with_time.<locals>.subscribe)N)r Z ObserverBaser r � SchedulerBaseZDisposableBaser )r r �r r )r r �skip_last_with_time" s �� z1skip_last_with_time_.<locals>.skip_last_with_time)r r )r r r# r r" r �skip_last_with_time_ s r$ )N)r r r r r r r Z reactivexr r Zreactivex.schedulerr r Z RelativeTimer! r$ �__all__r r r r �<module> s � � <
💾 Save Changes
❌ Cancel