🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 12:41:59 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/__pycache__
🔄 Refresh
✏️
Editing: _catch.cpython-38.pyc
Read Only
U v�i � @ s� d dl mZ d dlmZmZmZmZ d dlZd dlmZm Z d dl m Z m Z ed�Z ee eeee geee df f ee d�d d �Zeee eeee gee f f eee gee f d �d d �Zd gZdS )� )�Future)�Callable�Optional�TypeVar�UnionN)� Observable�abc)�SerialDisposable�SingleAssignmentDisposable�_Tz Future[_T])�source�handler�returnc s0 dt jt tt j t jd�� �fdd� }t|�S )N)�observer� schedulerr c sJ t � }t� �|�_td d��� ���fdd� }�j� j|� j�d�|_�S )N)� exceptionr c sz z� | ��}W n2 t k r@ } z��|� W Y �d S d }~X Y nX t|t�rVt�|�n|}t� }|�_|j��d�|_d S )N�r ) � Exception�on_error� isinstancer � reactivexZ from_futurer � disposable� subscribe)r �result�ex�d)r r r r � subscription� �K/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_catch.pyr s �z2catch_handler.<locals>.subscribe.<locals>.on_errorr )r r r r r Zon_nextZ on_completed)r r Zd1r �r r )r r r r r s �z catch_handler.<locals>.subscribe)N)r Z ObserverBaser r Z SchedulerBaseZDisposableBaser )r r r r r r � catch_handler s � �r )r r c s t t t t d�� fdd� }|S )N)r r c s" t � �rt| � �S t�| � �S dS )a� Continues an observable sequence that is terminated by an exception with the next observable sequence. Examples: >>> op = catch(ys) >>> op = catch(lambda ex, src: ys(ex)) Args: handler: Second observable sequence used to produce results when an error occurred in the first sequence, or an exception handler function that returns an observable sequence given the error and source observable that occurred in the first sequence. Returns: An observable sequence containing the first sequence's elements, followed by the elements of the handler sequence in case an exception occurred. N)�callabler r �catch)r �r r r r" 2 s zcatch_.<locals>.catch)r r )r r" r r# r �catch_- s r$ )�asyncior �typingr r r r r r r Zreactivex.disposabler r r r r r$ �__all__r r r r �<module> s � # �� !
💾 Save Changes
❌ Cancel