🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 11:34: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: _takeuntilwithtime.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)�end_time� scheduler�returnc s" t t t t d�� �fdd� }|S )N)�sourcer c s2 dt jt tt j t jd���� fdd� }t|�S )a� Takes elements for the specified duration until the specified end time, using the specified scheduler to run timers. Examples: >>> res = take_until_with_time(source) Args: source: Source observale to take elements from. Returns: An observable sequence with the elements taken until the specified end time. N)�observer� scheduler_r c s` �p|pt �� }dtjtd�� fdd� }t�t�r@|��|�}n |��|�}t |�j � |d��S )N�r �statec s � � � d S )N)Z on_completedr �r � �W/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_takeuntilwithtime.py�action$ s zVtake_until_with_time_.<locals>.take_until_with_time.<locals>.subscribe.<locals>.action)r )N) r Z singletonr � SchedulerBaser � isinstancer Zschedule_absoluteZschedule_relativer � subscribe)r r Z _schedulerr �task)r r r r r r s �zFtake_until_with_time_.<locals>.take_until_with_time.<locals>.subscribe)N)r Z ObserverBaser r r ZDisposableBaser )r r �r r )r r �take_until_with_time s ��z3take_until_with_time_.<locals>.take_until_with_time)r r )r r r r r r �take_until_with_time_ s #r )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