🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 13:09:39 | 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: onerrorresumenext.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZ d dlmZmZmZmZ d dlZd dlmZm Z d dl m Z m Z m Z d dlmZ ed�Zeee deee gee f f ee d �d d �Zd gZdS ) � )�Future)�Callable�Optional�TypeVar�UnionN)� Observable�abc)�CompositeDisposable�SerialDisposable�SingleAssignmentDisposable)�CurrentThreadScheduler�_Tz Future[_T])�sources�returnc s6 t | �� dtjt ttj tjd�� fdd� }t|�S )aQ Continues an observable sequence that is terminated normally or by an exception with the next observable sequence. Examples: >>> res = reactivex.on_error_resume_next(xs, ys, zs) Returns: An observable sequence that concatenates the source sequences, even if a sequence terminates exceptionally. N)�observer� schedulerr c sR |p t �� }t� �t� }dtjtt d d�� ���fdd� � |�� �|_t �|�S )N)r �stater c s� z t ��}W n tk r* ��� Y d S X t|�r<||�n|}t|t�rTt�|�n|}t� }|�_ dt t d d��� fdd� }|j �j ||� d�|_ d S )N)r r c s �� � | � d S )N)�schedule)r )�actionr � �W/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/onerrorresumenext.py� on_resume< s zKon_error_resume_next_.<locals>.subscribe.<locals>.action.<locals>.on_resume�r )N)�next� StopIterationZ on_completed�callable� isinstancer � reactivexZ from_futurer � disposabler � Exception� subscribeZon_next)r r �source�current�dr )r r �sources_� subscriptionr r r * s" � �z8on_error_resume_next_.<locals>.subscribe.<locals>.action)N) r Z singletonr r � SchedulerBaser r r r r )r r Z cancelable�r$ )r r r% r r " s � � z(on_error_resume_next_.<locals>.subscribe)N)�iterr Z ObserverBaser r r& ZDisposableBaser )r r r r' r �on_error_resume_next_ s � �$r) )�asyncior �typingr r r r r r r Zreactivex.disposabler r r Zreactivex.schedulerr r r r) �__all__r r r r �<module> s �� 9
💾 Save Changes
❌ Cancel