U
vi
@ sz d dl mZmZmZmZ d dlmZmZ d dlm Z m
Z
m Z m Z d dl
mZ edZeee ee dddZdgZd S )
)AnyIterableOptionalTypeVar)
Observableabc)CompositeDisposable
DisposableSerialDisposableSingleAssignmentDisposable)CurrentThreadScheduler_T)sourcesreturnc 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 ddtjtd d f dd
_d dfdd }tt |S ) NF) schedulerstater 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 }|_|jj|jd|_d S )N)exnr c s | _d S )N)schedule
disposable)r )
_scheduleraction
cancelablelast_exception K/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/catch.pyon_error- s zIcatch_with_iterable_..subscribe..action..on_error)r ) Exceptionnext
StopIterationr Z on_completedr r subscribeZon_next)r r r currentexd) r r r is_disposedr r r sources_ subscriptionr r r , s& z7catch_with_iterable_..subscribe..action)r c s d d S )NTr r )r% r r disposeJ s z8catch_with_iterable_..subscribe..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_..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 s D