U
vi @ st d dl mZmZmZmZ d dlmZmZ d dlm Z m
Z
d dl m Z ee ee eeedf dddZ
dgZd S )
)AnyListOptionalTuple)
Observableabc)CompositeDisposableSingleAssignmentDisposable)NotSet.)parentsourcesreturnc s8 t dtjt ttj tjd fdd
}t|S )N)observer schedulerr
c s8 t t t t tt d fdd }t|f S )N)r childrenr
c s fdd|D t tt td fdd t }td d fdd }fd dt|D } j|jjd
}||_|g| S ) Nc s g | ]} qS r ).0_)NO_VALUEr T/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/withlatestfrom.py
s zNwith_latest_from_..subscribe..subscribeall..)ichildr
c s6 t }td d fdd }|j|jd|_|S )Nvaluer
c s j | < W 5 Q R X d S N)lock)r )r r valuesr r on_next s zcwith_latest_from_..subscribe..subscribeall..subscribechild..on_nextr )r r subscribeon_error
disposable)r r Z subscriptionr )r r r r )r r subscribechild s zRwith_latest_from_..subscribe..subscribeall..subscribechildr c s6 j & kr(| ft }| W 5 Q R X d S r )r tupler )r result)r r r r r r r & s zKwith_latest_from_..subscribe..subscribeall..on_nextc s g | ]\}} ||qS r r )r r r )r# r r r , s r ) intr r r enumerater r! Z on_completedr" )r r Zparent_subscriptionr Zchildren_subscriptionZdisp)r r r )r r# r r subscribeall s$
z:with_latest_from_..subscribe..subscribeall)r r r r r )r r r( r r r )r r r r
s
&z$with_latest_from_..subscribe)N)r
r Z ObserverBaser r Z
SchedulerBaseZDisposableBaser )r r r r r) r with_latest_from_ s +r* N)typingr r r r Z reactivexr r Zreactivex.disposabler r Zreactivex.internal.utilsr
r* __all__r r r r s 3