U
vi @ s d dl mZmZmZmZmZmZ d dlmZm Z m Z d dl
m Z m Z m
Z
d dlmZ edZe jee j eee gee f dddZeegee f eee gee f d d
d Zdd gZd S )
)AnyCallableListOptionalTypeVarcast)
Observableabctyping)CompositeDisposableSerialDisposableSingleAssignmentDisposable)TimeoutScheduler_T)duetime schedulerreturnc s" t t t t d fdd }|S )Nsourcer c s2 dt jt tt j t jd fdd
}t|S )ay Ignores values from an observable sequence which are followed by
another value before duetime.
Example:
>>> res = debounce(source)
Args:
source: Source observable to debounce.
Returns:
An operator function that takes the source observable and
returns the debounced observable sequence.
N)observer
scheduler_r c s p|pt t dgttd gdg td d fdd }td d fdd }d d fd
d }j||||d }t|S )
NFr xr c sh dd< | d< d d7 < d t }|_dtjtd d fdd
}||_d S )NTr )r stater c s. d r" d kr" d dd< d S Nr F)on_next)r r )_id
current_id has_valuer value N/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_debounce.pyaction2 s zOdebounce_..debounce..subscribe..on_next..action)N)r
disposabler
SchedulerBaser Zschedule_relative)r dr# )r
_scheduler
cancelabler r r r )r r" r * s "z?debounce_..debounce..subscribe..on_next) exceptionr c s. | dd< d d7 < d S NFr r disposeon_error)r) r r( r r r! r" r- 9 s
z@debounce_..debounce..subscribe..on_errorr c sB d r d dd< d d7 < d S )Nr Fr r, r on_completedr! r r( r r r r! r" r1 ? s zDdebounce_..debounce..subscribe..on_completedr )r Z singletonr r r Exception subscriber )r r r r- r1 subscription)r r r )r r' r( r r r r" r5 s z.debounce_..debounce..subscribe)Nr Z ObserverBaser r r% ZDisposableBaser r r5 r r r r" debounce s -zdebounce_..debouncer r )r r r; r! r9 r" debounce_ s >r= )throttle_duration_mapperr c s t t t t d fdd }|S )Nr c s0 dt jt tt j t jd fdd
}t|S )a Partially applied throttle_with_mapper operator.
Ignores values from an observable sequence which are followed by
another value within a computed throttle duration.
Example:
>>> obs = throttle_with_mapper(source)
Args:
source: The observable source to throttle.
Returns:
The throttled observable sequence.
N)r r r c s t dttd dg td d fdd }td d fdd }d d fd
d }j|||d }t|S )
NFr r c
s d }z | }W n2 t k
rB } z| W Y d S d }~X Y nX d| d d7 < d t _td d fdd }d d fdd }|j|j|d
_d S ) NTr r r c s* r d kr d d S r r r, )r r r r& r r r r! r" r s
zhthrottle_with_mapper_..throttle_with_mapper..subscribe..on_next..on_nextr/ c s* r d kr d d S r r? r! r@ r! r" r1 s
zmthrottle_with_mapper_..throttle_with_mapper..subscribe..on_next..on_completedr3 )r4 r- r
r$ r r5 )r Zthrottleer r1 )r r( r r r r> r )r r& r" r n s(
zWthrottle_with_mapper_..throttle_with_mapper..subscribe..on_next)rA r c s* | d d d7 < d S r* r+ )rA r. r! r" r- s
zXthrottle_with_mapper_..throttle_with_mapper..subscribe..on_errorr/ c s6 r d d d7 < d S r* r0 r! r2 r! r" r1 s
z\throttle_with_mapper_..throttle_with_mapper..subscribe..on_completedr3 )r r r r4 r5 r )r r r r- r1 r6 )r r> )r r( r r r r r" r5 e s
%
zFthrottle_with_mapper_..throttle_with_mapper..subscribe)Nr7 r8 r> r: r" throttle_with_mapperU s Dz3throttle_with_mapper_..throttle_with_mapperr< )r> rC r! rB r" throttle_with_mapper_R s VrD N)r
r r r r r r Z reactivexr r Zreactivex.disposabler r r
Zreactivex.schedulerr r Z RelativeTimer% r= rD __all__r! r! r! r" s E \