U
vi @ s d dl mZmZmZmZmZ d dlmZmZm Z d dl m
Z
m Z m Z d dl
mZ edZe jeee f eee gee f dddZdgZd S )
)AnyCallableListOptionalTypeVar)
Observableabctyping)CompositeDisposableSerialDisposableSingleAssignmentDisposable)ImmediateScheduler_T)mapperreturnc s t t t t d fdd }|S )N)sourcer c s0 dt jt tt j t jd fdd
}t|S )a Expands an observable sequence by recursively invoking
mapper.
Args:
source: Source obserable to expand.
Returns:
An observable sequence containing all the elements produced
by the recursive expansion.
N)observer schedulerr c s^ p
t g t td d f dd d7 S )Nr Fc sN d} r } ddt jtd f dd
| rJ _d S )NFT)r statec s r d}ndd S t td d fdd }d d fdd }|j|j|| d _| _d S )
Nr F)valuer c
sj | d }z | }W n2 tk
rL } z| W Y d S d }~X Y nX | d7 d S )N )on_next Exceptionon_errorappend)r resultex) active_count
ensure_activer r queue L/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_expand.pyr = s
zbexpand_..expand..subscribe..ensure_active..action..on_next)r c s& d8 dkr" d S )Nr r )removeZ on_completedr )r dr sadr r! on_completeL s
zfexpand_..expand..subscribe..ensure_active..action..on_complete)r )popr addr subscriber
disposableschedule)r r Zworkr r% ) actionr r# r is_acquiredmr r r )r$ r! r+ 1 s
zQexpand_..expand..subscribe..ensure_active..action)N)r
SchedulerBaser r* r) )Zis_owner) r r# r r, r- r r r r )r+ r! r ) s ((zAexpand_..expand..subscribe..ensure_activer )r
Z singletonr r
r )r r )r r )r r# r r, r- r r r r! r( s 3
z*expand_..expand..subscribe)N)r Z ObserverBaser r r. ZDisposableBaser )r r( r )r r! expand s Dzexpand_..expand)r r )r r0 r r/ r! expand_ s Rr1 N)r r r r r r Z reactivexr r Zreactivex.disposabler
r r Zreactivex.schedulerr
r ZMapperr1 __all__r r r r! s X