U
vi @ s d dl mZ d dlmZmZmZmZ d dlZd dlmZm Z d dl
m Z m Z edZ
eeee
gee
f ddd Zd gZdS )
)Future)CallableOptionalTypeVarUnionN)
Observableabc)CompositeDisposableSingleAssignmentDisposable_Treturnc C s t t t t t ddd} | S )a! Performs a exclusive waiting for the first to finish before
subscribing to another observable. Observables that come in between
subscriptions will be dropped on the floor.
Returns:
An exclusive observable with only the results that
happen when subscribed.
)sourcer
c s. dt jt tt j t jd fdd
}t|S )N)observer schedulerr
c s| dgdgt }t | ttt df d d fdd }d d fdd }j|j|d |_ S )
NFz
Future[_T]) inner_sourcer
c sh d sddd< t | tr$t| n| } t fdd}| jjj|d _ d S )Nr Tc s2 dd< d r.t dkr. d S )NFr )removelen on_completed )g has_currentinner_subscription
is_stoppedr r O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_exclusive.pyon_completed_inner. s
z]exclusive_..exclusive..subscribe..on_next..on_completed_innerr )
isinstancer reactivexZ from_futurer
add subscribeon_nexton_error
disposable)r r r r r r r )r r r" ! s
zAexclusive_..exclusive..subscribe..on_nextr c s( dd< d s$t dkr$ d S )NTr r )r r r )r r r r r r r ; s zFexclusive_..exclusive..subscribe..on_completedr ) r
r r r r r r! r# r$ )r r mr" r r r% r r! s
( z0exclusive_..exclusive..subscribe)N)r Z ObserverBaser r Z
SchedulerBaseZDisposableBaser )r r! r r' r exclusive s /z exclusive_..exclusive)r r )r( r r r
exclusive_ s
2r) )asyncior typingr r r r r r r Zreactivex.disposabler r
r r) __all__r r r r s $?