🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 17:35:33 | 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: generate.cpython-38.pyc
Read Only
U v�io � @ s~ d dl mZmZmZmZ d dlmZmZm Z d dlm Z d dl m Z ed�Z e e j e e je e f ee d�dd�ZdgZd S ) � )�Any�Optional�TypeVar�cast)� Observable�abc�typing)� MultipleAssignmentDisposable)�CurrentThreadScheduler�_TState)� initial_state� condition�iterate�returnc s2 dt jt tt j t jd�� ��fdd� }t|�S )N)�observer� schedulerr c sP |p t �� }d���t� �dtjtd d�� ������fdd� � |�� ��_�S )NT)r �state1r c s� d}t td �}z&�rd�n�������}|r2�}W n2 tk rf } z��|� W Y �d S d }~X Y nX |r���|� | �� ��_n��� d S )NF)r r � ExceptionZon_errorZon_next�schedule� disposableZ on_completed)r r Z has_result�result� exception)�actionr �firstr �madr �state� �N/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/generate.pyr s z,generate_.<locals>.subscribe.<locals>.action)N)r Z singletonr r � SchedulerBaser r r )r r �r r r )r r r r r r � subscribe s & z generate_.<locals>.subscribe)N)r Z ObserverBaser r r ZDisposableBaser )r r r r r r r � generate_ s ��'r! N)r r r r r Z reactivexr r Zreactivex.disposabler Zreactivex.schedulerr r Z PredicateZMapperr! �__all__r r r r �<module> s � /
💾 Save Changes
❌ Cancel