U
vi
@ s d dl mZmZmZmZmZ d dlmZmZm Z d dl m
Z
m Z m Z edZ
d eee e jeee f df ee je
ee f eee
gee
f dddZdgZdS )
)AnyCallableOptionalTypeVarUnion)
Observableabctyping)CompositeDisposableSerialDisposableSingleAssignmentDisposable_TN)subscription_delaydelay_duration_mapperreturnc s" t t t t d fdd }|S )N)sourcer c sT dd t tjr n dtjt ttj tjd fdd
}t|S )a5 Time shifts the observable sequence based on a subscription
delay and a delay mapper function for each element.
Examples:
>>> obs = delay_with_selector(source)
Args:
subscription_delay: [Optional] Sequence indicating the
delay for the subscription to the source.
delay_duration_mapper: [Optional] Selector function to
retrieve a sequence indicating the delay for each given
element.
Returns:
Time-shifted observable sequence.
N)observer schedulerr c sl t dg fddt fdd sH n fddj_t S )NFc s d rj dkr d S )Nr )length on_completed )at_enddelaysr r U/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_delaywithmapper.pydone6 s zNdelay_with_mapper_..delay_with_mapper..subscribe..donec sL t d dfdd } d d fdd }j| j|d_d S )N)xr c
s zs
t }W n2 tk
rF } z| W Y d S d }~X Y nX t td d fdd }d d fdd }|j|j|d _d S )N)_r c s d S Non_nextremover dr r r r r r r H s
zqdelay_with_mapper_..delay_with_mapper..subscribe..start..on_next..on_nextr c s d S r r r r" r r r M s
zvdelay_with_mapper_..delay_with_mapper..subscribe..start..on_next..on_completedr )AssertionError Exceptionon_errorr addr subscribe
disposable)r delayerrorr r )r r mapperr r )r# r r r = s
z`delay_with_mapper_..delay_with_mapper..subscribe..start..on_nextr$ c s d d< d S )NTr )Zdisposer )r r subscriptionr r r V s zedelay_with_mapper_..delay_with_mapper..subscribe..start..on_completedr% )r
r* r( r+ )r r )r r r r. r r r r/ r r start< s zOdelay_with_mapper_..delay_with_mapper..subscribe..startc s S r r r! )r0 r r c zRdelay_with_mapper_..delay_with_mapper..subscribe..)r
r r* r( r+ )r r r. r Z sub_delay)r r r r r r0 r/ r r* / s #
z@delay_with_mapper_..delay_with_mapper..subscribe)N)
isinstancer ZObservableBaseZ ObserverBaser
r Z
SchedulerBaseZDisposableBaser )r r* r r r3 r delay_with_mapper s 9z-delay_with_mapper_..delay_with_mapper)r r
)r r r6 r r5 r delay_with_mapper_
s Ur7 )NN)r r r r r r Z reactivexr r Zreactivex.disposabler
r r r
ZMapperr7 __all__r r r r s `