U
vi @ s d dl mZ d dlmZmZmZmZ d dlZd dlmZm Z d dl
m Z m Z m
Z
d dlmZ edZeee deee gee f f ee d d
d Zd gZdS ) )Future)CallableOptionalTypeVarUnionN)
Observableabc)CompositeDisposableSerialDisposableSingleAssignmentDisposable)CurrentThreadScheduler_Tz
Future[_T])sourcesreturnc 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|trTt|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_..subscribe..action..on_resumer )N)next
StopIterationZ on_completedcallable
isinstancer reactivexZ from_futurer
disposabler Exception subscribeZon_next)r r sourcecurrentdr )r r sources_ subscriptionr r r * s" z8on_error_resume_next_..subscribe..action)N)
r Z singletonr
r
SchedulerBaser r r r r )r r Z
cancelabler$ )r r r% r r " s z(on_error_resume_next_..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 s 9