🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:29:56 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/__pycache__
🔄 Refresh
✏️
Editing: _zip.cpython-38.pyc
Read Only
U v�iO � @ s� d dl mZmZmZmZmZmZ d dlZd dlmZm Z ed�Z ed�Z ee eee geeedf f d�dd �Z ee eee geee e f f d �d d �Z d d gZdS ) � )�Any�Callable�Iterable�Optional�Tuple�TypeVarN)� Observable�abc�_T�_TOther.)�args�returnc s( t t t ttdf d�� fdd� }|S )N.��sourcer c s t j| f� �� 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(source) Args: source: Source observable to zip. Returns: An observable sequence containing the result of combining elements of the sources as a tuple. )� reactivex�zip)r �r � �I/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_zip.py�_zip s zzip_.<locals>._zip)r r r )r r r r r �zip_ s $r )�seqr c s( t t t tttf d�� fdd� }|S )Nr c s@ | � t ���dtjtttf ttj d�� �fdd� }t|�S )a� Merges the specified observable sequence and list 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(source) Args: source: Source observable to zip. Returns: An observable sequence containing the result of combining elements of the sources as a tuple. N)�observer� schedulerc s2 d� t d d�� ��fdd� }�j|�j�j|d�S )Nr )�leftr c s@ z t ��}W n tk r( ��� Y nX | |f}��|� d S )N)�next� StopIteration� on_completed�on_next)r �right�result)�indexr �secondr r r ? s zQzip_with_iterable_.<locals>.zip_with_iterable.<locals>.subscribe.<locals>.on_next)r )r � subscribeZon_errorr )r r r ��firstr" )r! r r r# 9 s �z@zip_with_iterable_.<locals>.zip_with_iterable.<locals>.subscribe)N) �iterr Z ObserverBaser r r r Z SchedulerBaser )r r# �r r$ r �zip_with_iterable% s ��z-zip_with_iterable_.<locals>.zip_with_iterable)r r r r )r r( r r' r �zip_with_iterable_" s $+r) )�typingr r r r r r r r r r r r r) �__all__r r r r �<module> s � � 1
💾 Save Changes
❌ Cancel