U
viO @ s d dl mZmZmZmZmZmZ d dlZd dlmZm Z edZ
edZ ee eee geeedf f ddd Z ee eee
geee
e f f d
d d Z
d d gZdS )
)AnyCallableIterableOptionalTupleTypeVarN)
Observableabc_T_TOther.)argsreturnc 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.
) reactivexzip)r r I/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_zip.py_zip
s zzip_.._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|jj|dS )Nr )leftr
c s@ z t }W n tk
r( Y nX | |f}| d S )N)next
StopIteration on_completedon_next)r rightresult)indexr secondr r r ? s zQzip_with_iterable_..zip_with_iterable..subscribe..on_next)r )r
subscribeZon_errorr )r r r firstr" )r! r r r# 9 s z@zip_with_iterable_..zip_with_iterable..subscribe)N) iterr Z ObserverBaser r
r r Z
SchedulerBaser )r r# r r$ r zip_with_iterable% s z-zip_with_iterable_..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 s 1