🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:38:14 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
observable
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/__pycache__
🔄 Refresh
✏️
Editing: generatewithrelativetime.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZmZmZmZmZ d dlmZmZ d dl m Z d dl m Z d dl mZmZmZ ed�Zeee eeef eegef ee d�dd �Zd gZd S ) � )�Any�Callable�Optional�TypeVar�cast)� Observable�abc)� MultipleAssignmentDisposable)�TimeoutScheduler)�Mapper� Predicate� RelativeTime�_TState)� initial_state� condition�iterate� time_mapper�returnc s4 dt jt tt j t jd�� ���fdd� }t|�S )a� Generates an observable sequence by iterating a state from an initial state until the condition fails. Example: res = source.generate_with_relative_time( 0, lambda x: True, lambda x: x + 1, lambda x: 0.5 ) Args: initial_state: Initial state. condition: Condition to terminate generation (upon returning false). iterate: Iteration step function. time_mapper: Time mapper function to control the speed of values being produced each iteration, returning relative times, i.e. either floats denoting seconds or instances of timedelta. Returns: The generated sequence. N)�observer� schedulerr c sj |p t �� }t� �� �d�ttd ��d�d �tjtd d�� ���� ������ f dd� � |�d� ��_ �S )NFT)r �_r c s� �r�� �� z.�rd�n���������r:��� ��� W n2 tk rn } z��|� W Y �d S d }~X Y nX �r�� s|t�| �� � ��_n��� d S )NF)Zon_next� ExceptionZon_error�AssertionError�schedule_relative� disposableZ on_completed)r r �e) �actionr �first� has_resultr �madr �result�state�timer � �^/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/generatewithrelativetime.pyr 3 s" z?generate_with_relative_time_.<locals>.subscribe.<locals>.actionr ) r Z singletonr r r r � SchedulerBaser r r )r r �r r r r )r r r r r r r! r" r$ � subscribe' s , z/generate_with_relative_time_.<locals>.subscribe)N)r Z ObserverBaser r r% ZDisposableBaser )r r r r r' r# r& r$ � generate_with_relative_time_ s ��/r( N)�typingr r r r r Z reactivexr r Zreactivex.disposabler Zreactivex.schedulerr Zreactivex.typingr r r r r( �__all__r# r# r# r$ �<module> s � N
💾 Save Changes
❌ Cancel