U
vi @ sb d dl mZmZmZmZ d dlmZmZ d dlm Z m
Z
ee eeedf dddZ dgZ dS ) )AnyListOptionalTuple)
Observableabc)CompositeDisposableSingleAssignmentDisposable.)sourcesreturnc s6 d dt jt tt j td fdd
}t|S )ae Merges the specified observable sequences into one observable
sequence by creating a tuple whenever any of the
observable sequences produces an element.
Examples:
>>> obs = combine_latest(obs1, obs2, obs3)
Returns:
An observable sequence containing the result of combining
elements of the sources into a tuple.
r N)observer schedulerr c s t
}dg| dgdg| d g| td dfdd td dfdd d g| td d
fdd }t|D ] }|| qtS ) NF)ir c s^ d < d st r,t}| n"t fddtD rN t d< d S )NTr c s g | ]\}}| kr|qS r ).0jxr r S/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/combinelatest.py
' s zEcombine_latest_..subscribe.._next..)alltupleon_next enumerate on_completed)r res) has_value
has_value_allis_doner valuesr r _next s z1combine_latest_..subscribe.._nextc s d | < t r d S )NT)r r r )r r r r done, s z0combine_latest_..subscribe..donec sh t < td d fdd }d d fdd } }|sJt j|j|d|_d S )N)r r c s& j | < W 5 Q R X d S Nlock)r )r r parentr r r r 6 s zAcombine_latest_..subscribe..func..on_next)r c s j W 5 Q R X d S r" r# r )r! r r% r r r ; s zFcombine_latest_..subscribe..func..on_completed)r
)r r AssertionError subscribeZon_errorZ
disposable)r r r Z subscription)r r! r r% r
r
subscriptionsr r r func3 s
z0combine_latest_..subscribe..func)lenr intranger )r r
nr) idxr% r
) r r! r r r r r
r( r r r' s
"
z"combine_latest_..subscribe)N)r Z ObserverBaser r Z
SchedulerBaser r )r
r' r r/ r combine_latest_ s
3r0 N)
typingr r r r Z reactivexr r Zreactivex.disposabler r r0 __all__r r r r s E