U
vi @ sf d dl mZmZmZmZmZ d dlmZmZ d dl m
Z
m Z ee eeedf dddZ dgZ
dS ) )AnyListOptionalTuplecast)
Observableabc)CompositeDisposableSingleAssignmentDisposable.)sourcesreturnc s@ d dt jttdf tt j t jd fdd
}t|S )a Wait for observables to complete and then combine last values
they emitted into a tuple. Whenever any of that observables completes
without emitting any value, result sequence will complete at that moment as well.
Examples:
>>> obs = reactivex.fork_join(obs1, obs2, obs3)
Returns:
An observable sequence containing the result of combining last element from
each source in given sequence.
r N.)observer schedulerr c s t }d g| dg| dg| td dfdd ttd g| td d fdd }t|D ] }|| qztS )NF)ir c sP d| < | s d S trLt rDt n d S NT) on_completedallon_nexttupler ) has_valueis_doner
values N/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/forkjoin.pydone s
z+fork_join_..subscribe..donec s\ t < td d fdd }d d fdd } j|j|d _d S )N)valuer c s& j | < d < W 5 Q R X d S r lock)r )r r parentr r r r 4 s zBfork_join_..subscribe.._subscribe..on_next)r c s j W 5 Q R X d S )Nr r )r r r r r r 9 s zGfork_join_..subscribe.._subscribe..on_completed)r )r
r subscribeZon_errorZ
disposable)r r r )r r r
r r r
subscriptionsr r r
_subscribe1 s
z1fork_join_..subscribe.._subscribe)lenintr r
ranger )r
r nr" r r r )r r r r
r r! r r r s
"
z fork_join_..subscribe)N)r Z ObserverBaser r r Z
SchedulerBaseZDisposableBaser )r r r r' r
fork_join_ s
/r( N)typingr r r r r Z reactivexr r Zreactivex.disposabler r
r( __all__r r r r s A