U
vi @ s d dl mZmZmZmZ d dlmZmZm Z d dlm Z d dl
m Z edZ d
e j
eej eee gee f ddd Zd gZdS ) )AnyCallableOptionalTypeVar)
Observableabctyping)CompositeDisposable)TimeoutScheduler_TN)duration schedulerreturnc s" t t t t d fdd }|S )N)sourcer c s. dt jt tt j d fdd
}t|S )a Skips elements for the specified duration from the start of
the observable source sequence.
Args:
>>> res = skip_with_time(5.0)
Specifying a zero value for duration doesn't guarantee no
elements will be dropped from the start of the source sequence.
This is a side-effect of the asynchrony introduced by the
scheduler, where the action that causes callbacks from the
source sequence to be forwarded may not execute immediately,
despite the zero due time.
Errors produced by the source sequence are always forwarded to
the result sequence, even if the error occurs before the
duration.
Args:
duration: Duration for skipping elements from the start of
the sequence.
Returns:
An observable sequence with the elements skipped during the
specified duration from the start of the source sequence.
N)observer
scheduler_c sn p|pt }dgtjtd dfdd }||}td fdd }j| j j |d}t
||S ) NF)r
stater c s d d< d S )NTr )r
r )openr R/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_skipwithtime.pyaction/ s zJskip_with_time_..skip_with_time..subscribe..actionxc s d r | d S )Nr )on_nextr r r r r r 4 s zKskip_with_time_..skip_with_time..subscribe..on_next)r
) r
Z singletonr
SchedulerBaser Zschedule_relativer subscribeZon_errorZ on_completedr )r r Z
_schedulerr tr d)r r
r r r r ( s z:skip_with_time_..skip_with_time..subscribe)N)r Z ObserverBaser r r r )r r r r
)r r skip_with_time
s z'skip_with_time_..skip_with_time)r r )r r
r r r r skip_with_time_
s 2r! )N)r r r r r Z reactivexr r Zreactivex.disposabler Zreactivex.schedulerr
r Z RelativeTimer r! __all__r r r r s 8