🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 12:45:10 | 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: _skipwithtime.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZmZmZmZ d dlmZmZm Z d dlm Z d dl m Z ed�Z d e j eej eee gee f d�dd �Zd gZdS ) � )�Any�Callable�Optional�TypeVar)� Observable�abc�typing)�CompositeDisposable)�TimeoutScheduler�_TN)�duration� scheduler�returnc s" t t t t d�� �fdd� }|S )N)�sourcer c s. dt jt tt j d���� fdd� }t|�S )a� Skips elements for the specified duration from the start of the observable source sequence. Args: >>> res = skip_with_time(5.0) Specifying a zero value for duration doesn't guarantee no elements will be dropped from the start of the source sequence. This is a side-effect of the asynchrony introduced by the scheduler, where the action that causes callbacks from the source sequence to be forwarded may not execute immediately, despite the zero due time. Errors produced by the source sequence are always forwarded to the result sequence, even if the error occurs before the duration. Args: duration: Duration for skipping elements from the start of the sequence. Returns: An observable sequence with the elements skipped during the specified duration from the start of the source sequence. N)�observer� scheduler_c sn �p|pt �� }dg�tjtd d��fdd� }|��|�}td�� �fdd� }�j|� j� j |d�}t ||�S ) NF)r �stater c s d� d< d S )NTr � )r r )�openr �R/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_skipwithtime.py�action/ s zJskip_with_time_.<locals>.skip_with_time.<locals>.subscribe.<locals>.action��xc s �d r� � | � d S )Nr )�on_nextr �r r r r r 4 s zKskip_with_time_.<locals>.skip_with_time.<locals>.subscribe.<locals>.on_next)r ) r Z singletonr � SchedulerBaser Zschedule_relativer � subscribeZon_errorZ on_completedr )r r Z _schedulerr �tr �d)r r r r r r ( s �z:skip_with_time_.<locals>.skip_with_time.<locals>.subscribe)N)r Z ObserverBaser r r r )r r �r r )r r �skip_with_time s ��z'skip_with_time_.<locals>.skip_with_time)r r )r r r r r r �skip_with_time_ s 2r! )N)r r r r r Z reactivexr r Zreactivex.disposabler Zreactivex.schedulerr r Z RelativeTimer r! �__all__r r r r �<module> s � � 8
💾 Save Changes
❌ Cancel