🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:22:27 | 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: zip.cpython-38.pyc
Read Only
U v�i � @ s� d dl mZ d dlmZ d dlmZmZmZmZ d dl m Z m Z m Z d dl mZmZ d dlmZ e e e eedf d�d d �Zd gZd S ) � )�Future)�RLock)�Any�List�Optional�Tuple)� Observable�abc� from_future)�CompositeDisposable�SingleAssignmentDisposable)� synchronized.)�args�returnc s4 t | �� dtjt ttj td�� fdd� }t|�S )a� Merges the specified observable sequences into one observable sequence by creating a tuple whenever all of the observable sequences have produced an element at a corresponding index. Example: >>> res = zip(obs1, obs2) Args: args: Observable sources to zip. Returns: An observable sequence containing the result of combining elements of the sources as tuple. N)�observer� schedulerr c s� t ��}dd� t|�D ��t� }dg| �t|�td d����fdd� ��td d����fdd� � d g| �td d�� ������fd d � }t|�D ] }||� q�t��S ) Nc S s g | ]}g �qS � r )�.0�_r r �I/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/zip.py� <listcomp>! s z+zip_.<locals>.subscribe.<locals>.<listcomp>F)�ir c s� t dd� �D ��r�zdd� �D �}t|�}W n2 tk r^ } z��|� W Y �d S d }~X Y nX ��|� tdd� t�� �D ��r���� d S )Nc s s | ]}t |�V qd S �N��len)r �qr r r � <genexpr>' s z9zip_.<locals>.subscribe.<locals>.next_.<locals>.<genexpr>c S s g | ]}|� d ��qS )r )�pop)r �xr r r r ) s z:zip_.<locals>.subscribe.<locals>.next_.<locals>.<listcomp>c s s" | ]\}}t |�d kr|V qdS )r Nr )r �queue�doner r r r 4 s �)�all�tuple� Exception�on_error�on_next�any�zip� on_completed)r Z queued_values�res�ex�� is_completedr �queuesr r �next_% s ��z&zip_.<locals>.subscribe.<locals>.next_c s$ d� | < t �| �dkr ��� d S )NTr )r r( �r r+ r r � completed< s z*zip_.<locals>.subscribe.<locals>.completedc sd �� }t |t�rt|�}t� }td d�� ��fdd� }|j|�j�� fdd��d�|_|�� < d S )N)r r c s �� � | � �� � d S r )�append)r )r r. r- r r r% J s z6zip_.<locals>.subscribe.<locals>.func.<locals>.on_nextc s � ��S r r r )r0 r r r �<lambda>O � z7zip_.<locals>.subscribe.<locals>.func.<locals>.<lambda>)r )� isinstancer r r r � subscriber$ Z disposable)r �sourceZsadr% )r0 r. r r- r �sources� subscriptionsr/ r �funcC s �z%zip_.<locals>.subscribe.<locals>.func)r �ranger r �intr )r r �n�lockr9 �idx�r7 )r0 r, r. r r- r r8 r r5 s zzip_.<locals>.subscribe)N)�listr Z ObserverBaser r Z SchedulerBaser r )r r5 r r? r �zip_ s � �:rA N)�asyncior � threadingr �typingr r r r Z reactivexr r r Zreactivex.disposabler r Zreactivex.internalr rA �__all__r r r r �<module> s P
💾 Save Changes
❌ Cancel