U
viA @ s d dl mZ d dlmZmZmZmZmZ d dlZd dlm Z m
Z
m Z mZ d dl m
Z
mZ d dlmZ edZdde e ee ee e e ge e f d d
d Zee e e ge e f d d
dZd dgZdS ) )Future)CallableListOptionalTypeVarUnionN)
Observableabc from_futuretyping)CompositeDisposableSingleAssignmentDisposable) synchronized_T)max_concurrent)sourcesr returnc s& t t t t t d fdd }|S )Nsourcer c sL dkr t g }tj| S dtjt ttj d fdd
}t|S )a Merges an observable sequence of observable sequences into
an observable sequence, limiting the number of concurrent
subscriptions to inner sequences. Or merges two observable
sequences into a single observable sequence.
Examples:
>>> res = merge(sources)
Args:
source: Source observable.
Returns:
The observable sequence that merges the elements of the
inner sequences.
Nobserver schedulerc s dg t dgg tt d fdd tt d d fdd } fd d
}j|j|d S ) Nr F)xsc sj t tj fdd}tjj}tjj}| j|||d _d S )Nc sR r"d} | n, d d8 < d rN d dkrN d S Nr )removepop on_completed)s) active_countgroup
is_stoppedr queue subscribe subscription K/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_merge.pyr 1 s
zQmerge_..merge..subscribe..subscribe..on_completedr )r
addr lockon_nexton_errorr#
disposable)r r r* r+ )r r r! r r" r r r# )r$ r& r# - s
z;merge_..merge..subscribe..subscribe) inner_sourcer c s< st d k r. d d7 < | n
| d S r )AssertionErrorappendr- )r r r" r# r% r& r* B s
z9merge_..merge..subscribe..on_nextc s dd< d dkr d S )NTr )r r% )r r! r r% r& r J s z>merge_..merge..subscribe..on_completedr' )r r r r( r# r+ )r r r* r )r r )r r r! r r" r r# r& r# $ s $ z(merge_..merge..subscribe)N) tuple reactivexmerger ObserverBaser r
SchedulerBaser )r Zsources_r# r r r r& r3 s
2zmerge_..merger r )r r r3 r% r6 r& merge_ s "Ir9 )r c C s t t t t t ddd} | S )Nr c s* dt jt tt j d fdd
}t|S )aD Partially applied merge_all operator.
Merges an observable sequence of observable sequences into an
observable sequence.
Args:
source: Source observable to merge.
Returns:
The observable sequence that merges the elements of the inner
sequences.
Nr c sl t dgt } | ttt df d fdd } fdd}j|j|d|_ S ) NFz
Future[_T]r0 c s~ t t| tr"t| n| } tj fdd}tjj}tjj}| j |||d}| _
d S )Nc s* d r&t dkr& d S r )r lenr r% )r inner_subscriptionr! r r% r& r } s
zWmerge_all_..merge_all..subscribe..on_next..on_completedr' ) r
r(
isinstancer r
r r) r* r+ r# r, )r- r r* r+ r$ )r r! r r r )r; r& r* s s"
zAmerge_all_..merge_all..subscribe..on_nextc s dd< t dkr d S )NTr r )r: r r% )r r! r r% r& r s zFmerge_all_..merge_all..subscribe..on_completedr' ) r r
r( r r r r# r+ r, )r r mr* r r7 )r r! r r r& r# j s
& z0merge_all_..merge_all..subscribe)N)r r4 r r r5 r )r r# r% r7 r& merge_all\ s *z merge_all_..merge_allr8 )r> r% r% r&
merge_all_[ s :r? )asyncior r r r r r r r2 r r r
Zreactivex.disposabler r
Zreactivex.internalr r intr9 r? __all__r% r% r% r& s O$>