U
vi @ s d dl mZmZmZmZ d dlZd dlmZmZ d dlmZ d dlm Z edZ
d
e j eej eee
gee
f ddd Z
d gZdS ) )AnyCallableOptionalTypeVarN)
Observableabc) operators)typing_T)duetime schedulerreturnc s" t t t t d fdd }|S )N)sourcer
c s0 t tt ddd}| ttj d|S )a Time shifts the observable sequence by delaying the subscription.
Exampeles.
>>> res = source.delay_subscription(5)
Args:
source: Source subscription to delay.
Returns:
Time-shifted sequence.
)_r
c S s t S )N) reactivexempty)r r W/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_delaysubscription.pymapper s z?delay_subscription_..delay_subscription..mapper)r )r r r
pipeopsZdelay_with_mapperr timer)r r r r r r delay_subscription s
z/delay_subscription_..delay_subscription)r r
)r r r r r r delay_subscription_ s r )N)r r r r r r r r r r r
ZAbsoluteOrRelativeTimeZ
SchedulerBaser __all__r r r r s