🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:22:25 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
observable
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/__pycache__
🔄 Refresh
✏️
Editing: combinelatest.cpython-38.pyc
Read Only
U v�i� � @ sb d dl mZmZmZmZ d dlmZmZ d dlm Z m Z ee eeedf d�dd�Z dgZ dS ) � )�Any�List�Optional�Tuple)� Observable�abc)�CompositeDisposable�SingleAssignmentDisposable.)�sources�returnc 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| �dg�dg| �d g| �td d������fdd� � td d���fdd� �d g| �td d�� ��� �� ��fdd� }t|�D ] }||� q�t��S ) NF)�ir c s^ d�� < �d st ��r,t��}��|� n"t � fdd�t��D ��rN��� t ���d< d S )NTr c s g | ]\}}|� kr|�qS � r )�.0�j�x�r r �S/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/combinelatest.py� <listcomp>' s zEcombine_latest_.<locals>.subscribe.<locals>._next.<locals>.<listcomp>)�all�tuple�on_next� enumerate� on_completed)r �res)� has_value� has_value_all�is_doner �valuesr r �_next s z1combine_latest_.<locals>.subscribe.<locals>._nextc s d� | < t � �r��� d S )NT)r r r )r r r r �done, s z0combine_latest_.<locals>.subscribe.<locals>.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 �N��lock)r )r r �parentr r r r 6 s zAcombine_latest_.<locals>.subscribe.<locals>.func.<locals>.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_.<locals>.subscribe.<locals>.func.<locals>.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_.<locals>.subscribe.<locals>.func)�lenr �int�ranger )r r �nr) �idx�r% r ) r r! r r r r r r( r r r' s " z"combine_latest_.<locals>.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 �<module> s E
💾 Save Changes
❌ Cancel