🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:32:11 | 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: concat.cpython-38.pyc
Read Only
U v�i\ � @ sz d dl mZmZmZmZ d dlmZmZ d dlm Z m Z m Z m Z d dl mZ ed�Zeee ee d�dd�ZdgZd S ) � )�Any�Iterable�Optional�TypeVar)� Observable�abc)�CompositeDisposable� Disposable�SerialDisposable�SingleAssignmentDisposable)�CurrentThreadScheduler�_T)�sources�returnc s. dt jt tt j t jd�� fdd� }t|�S )N)�observer� scheduler_r c sz �p t �� � t���t� �t� �d�dtjtd d�� �������fdd� �� ����_d d��fdd� }t ��t |��S ) NF)� scheduler�stater c s� �rd S d d�� ��fdd� }z t ��}W nF tk rF ��� Y nP tk rp } z��|� W 5 d }~X Y n&X t� }|�_|j�j�j|�d�|_d S )N�r c s � � ���_d S )N)�schedule� disposable� )� _scheduler�action� cancelabler �L/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/concat.py� on_completed s zNconcat_with_iterable_.<locals>.subscribe.<locals>.action.<locals>.on_completed)r ) �next� StopIterationr � ExceptionZon_errorr r � subscribeZon_next)r r r �current�ex�d�r r r � is_disposedr r Zsources_Z subscriptionr r r s" �z8concat_with_iterable_.<locals>.subscribe.<locals>.actionr c s d� d S )NTr r )r% r r �dispose5 s z9concat_with_iterable_.<locals>.subscribe.<locals>.dispose)N) r Z singleton�iterr r � SchedulerBaser r r r r )r r r& �r r$ r r s ( z(concat_with_iterable_.<locals>.subscribe)N)r Z ObserverBaser r r( ZDisposableBaser )r r r r) r �concat_with_iterable_ s � �+r* N)�typingr r r r Z reactivexr r Zreactivex.disposabler r r r Zreactivex.schedulerr r r* �__all__r r r r �<module> s /
💾 Save Changes
❌ Cancel