U
vi\ @ s d dl mZ d dlmZmZmZmZmZ d dlm Z m
Z
m Z d dl m
Z
mZmZ edZee ee e df ge e f ddd Zd gZd
S ) )Future)AnyCallableOptionalTypeVarUnion)
Observableabc from_future)CompositeDisposableSerialDisposableSingleAssignmentDisposable_T
Future[_T]returnc C s( t tt t df t t ddd} | S )Nr )sourcer c s. dt jt tt j t jd fdd
}t|S )a Partially applied switch_latest operator.
Transforms an observable sequence of observable sequences into
an observable sequence producing values only from the most
recent observable sequence.
Returns:
An observable sequence that at any point in time produces
the elements of the most recent inner observable sequence
that has been received.
N)observer schedulerr c sx t dg dgdgttt df d d fdd }d d fdd }j|j|d
}t|S ) NFr r ) inner_sourcer c s t }j d d7 < d W 5 Q R X dd< |_t| trRt| }n| }td d fdd }td d fdd }d d
fd d }|j|||d
|_d S )Nr T)xr c s d kr | d S Nr )on_next)r _idlatestr R/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_switchlatest.pyr 9 s zZswitch_latest_..switch_latest..subscribe..on_next..on_next)er c s d kr | d S r )on_error)r r r r r = s z[switch_latest_..switch_latest..subscribe..on_next..on_errorr c s( d kr$dd< d r$ d S )Nr F on_completedr )r
has_latest
is_stoppedr r r r r" A s z_switch_latest_..switch_latest..subscribe..on_next..on_completedr ) r
lockZ
disposable
isinstancer r
r Exception subscribe)r dZobsr r r" )r# inner_subscriptionr$ r r r r )r r r ) s$
zIswitch_latest_..switch_latest..subscribe..on_nextr c s dd< d s d S )NTr r! r )r# r$ r r r r" K s zNswitch_latest_..switch_latest..subscribe..on_completedr% )r r r r r) r r )r r r r" Z subscriptionr )r# r+ r$ r r r r r) s ," z8switch_latest_..switch_latest..subscribe)N)r Z ObserverBaser r Z
SchedulerBaseZDisposableBaser )r r) r r, r
switch_latest s 5z%switch_latest_..switch_latest)r r r )r- r r r switch_latest_ s Fr. N)asyncior typingr r r r r Z reactivexr r r
Zreactivex.disposabler r r
r r. __all__r r r r s L