🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 13:47:54 | 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: catch.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 s6 t | �� dtjt ttj tjd�� fdd� }t|�S )a� Continues an observable sequence that is terminated by an exception with the next observable sequence. Examples: >>> res = catch([xs, ys, zs]) >>> res = reactivex.catch(src for src in [xs, ys, zs]) Args: sources: an Iterable of observables. Thus a generator is accepted. Returns: An observable sequence containing elements from consecutive source sequences until a source sequence terminates successfully. N)�observer� scheduler_r c sx �p t �� � t� �t� �d �d�dtjtd d�� ��������f dd� �� ����_d d��fdd� }t��t |��S ) NF)� scheduler�stater c s� t d d�� ���fdd� }�r"d S z t��}W nV tk rZ �rN���� n��� Y nP t k r� } z��|� W 5 d }~X Y n&X t� }|�_|j�j|�j�d�|_d S )N)�exnr c s | �� � ���_d S )N)�schedule� disposable)r )� _scheduler�action� cancelable�last_exception� �K/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/catch.py�on_error- s zIcatch_with_iterable_.<locals>.subscribe.<locals>.action.<locals>.on_error)r ) � Exception�next� StopIterationr Z on_completedr r � subscribeZon_next)r r r �current�ex�d) r r r � is_disposedr r r �sources_� subscriptionr r r , s& �z7catch_with_iterable_.<locals>.subscribe.<locals>.action)r c s d� d S )NTr r )r% r r �disposeJ s z8catch_with_iterable_.<locals>.subscribe.<locals>.dispose)N) r Z singletonr r � SchedulerBaser r r r r )r r r( �r& )r r r r% r r r r' r r! " s * z'catch_with_iterable_.<locals>.subscribe)N)�iterr Z ObserverBaser r r) ZDisposableBaser )r r! r r* r �catch_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 D
💾 Save Changes
❌ Cancel