🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:29:00 | 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: _skipuntilwithtime.cpython-38.pyc
Read Only
U v�i� � @ s� d dl m Z d dlmZmZmZmZ d dlmZmZmZ d dl m Z d dl m Z ed�Z d ejeej eee gee f d�d d �Zd gZdS ) � )�datetime)�Any�Callable�Optional�TypeVar)� Observable�abc�typing)�CompositeDisposable)�TimeoutScheduler�_TN)� start_time� scheduler�returnc s" t t t t d�� �fdd� }|S )N)�sourcer c sD t �t�rd� nd� dtjt ttj d��� ��fdd� }t|�S )a� Skips elements from the observable source sequence until the specified start time. Errors produced by the source sequence are always forwarded to the result sequence, even if the error occurs before the start time. Examples: >>> res = source.skip_until_with_time(datetime) >>> res = source.skip_until_with_time(5.0) Args: start_time: Time to start taking elements from the source sequence. If this value is less than or equal to `datetime.utcnow`, no elements will be skipped. Returns: An observable sequence with the elements skipped until the specified start time. Zschedule_absoluteZschedule_relativeN)�observer� scheduler_c sr �p|pt �� }dg�td d�� �fdd� }�j|� j� j|d�}tjtd��fdd� }t |���|�}t ||�S ) NF)�xr c s �d r� � | � d S )Nr )�on_next)r �r �open� �W/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_skipuntilwithtime.pyr 2 s zWskip_until_with_time_.<locals>.skip_until_with_time.<locals>.subscribe.<locals>.on_next)r �r �statec s d� d< d S )NTr r r )r r r �action: s zVskip_until_with_time_.<locals>.skip_until_with_time.<locals>.subscribe.<locals>.action) r Z singletonr � subscribeZon_errorZ on_completedr � SchedulerBaser �getattrr )r r Z _schedulerr Z subscriptionr Zdisp)r �scheduler_methodr r r r r * s �zFskip_until_with_time_.<locals>.skip_until_with_time.<locals>.subscribe)N)� isinstancer r Z ObserverBaser r r r )r r �r r )r r r �skip_until_with_time s ��z3skip_until_with_time_.<locals>.skip_until_with_time)r r )r r r" r r! r �skip_until_with_time_ s 3r# )N)r r r r r r Z reactivexr r Zreactivex.disposabler Zreactivex.schedulerr r ZAbsoluteOrRelativeTimer r# �__all__r r r r �<module> s �� :
💾 Save Changes
❌ Cancel