🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:29:27 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/__pycache__
🔄 Refresh
✏️
Editing: _debounce.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZmZmZmZmZmZ d dlmZm Z m Z d dl m Z m Z m Z d dlmZ ed�Ze jee j eee gee f d�dd�Zeegee f eee gee f d �d d �Zdd gZd S ) � )�Any�Callable�List�Optional�TypeVar�cast)� Observable�abc�typing)�CompositeDisposable�SerialDisposable�SingleAssignmentDisposable)�TimeoutScheduler�_T)�duetime� scheduler�returnc s" t t t t d�� �fdd� }|S )N��sourcer 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� �dg�ttd �g�dg� td d�� ������fdd� }td d�� ���fdd� }d d �� ����fd d � }�j||||d �}t|��S ) NFr ��xr c sh d�d< | �d< �d d7 < �d � t � }|�_dtjtd d��� ���fdd� }���|�|_d S )NTr � )r �stater c s. �d r"� d �kr"�� �d � d�d< 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.py�action2 s zOdebounce_.<locals>.debounce.<locals>.subscribe.<locals>.on_next.<locals>.action)N)r � disposabler � SchedulerBaser Zschedule_relative)r �dr# )r � _scheduler� cancelabler r r r )r r" r * s "z?debounce_.<locals>.debounce.<locals>.subscribe.<locals>.on_next)� exceptionr c s. �� � ��| � d�d< � d d7 < d S �NFr r ��dispose�on_error)r) �r r( r r r! r" r- 9 s z@debounce_.<locals>.debounce.<locals>.subscribe.<locals>.on_error�r c sB �� � �d r ���d � ��� d�d< � d d7 < d S )Nr Fr �r, r � on_completedr! �r r( r r r r! r" r1 ? s zDdebounce_.<locals>.debounce.<locals>.subscribe.<locals>.on_completed�r )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_.<locals>.debounce.<locals>.subscribe)N�r Z ObserverBaser r r% ZDisposableBaser �r r5 �r r �r r" �debounce s ��-zdebounce_.<locals>.debounce�r 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 � �d�ttd ��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_.<locals>.throttle_with_mapper.<locals>.subscribe.<locals>.on_next.<locals>.on_nextr/ c s* �r� d �kr�� �� d���� d S r r? r! r@ r! r" r1 � s zmthrottle_with_mapper_.<locals>.throttle_with_mapper.<locals>.subscribe.<locals>.on_next.<locals>.on_completedr3 )r4 r- r r$ r r5 )r Zthrottle�er r1 )r r( r r r r> r )r r& r" r n s( �zWthrottle_with_mapper_.<locals>.throttle_with_mapper.<locals>.subscribe.<locals>.on_next)rA r c s* �� � ��| � d�� d d7 < d S r* r+ )rA r. r! r" r- � s zXthrottle_with_mapper_.<locals>.throttle_with_mapper.<locals>.subscribe.<locals>.on_errorr/ c s6 �� � �r���� ��� d�� d d7 < d S r* r0 r! r2 r! r" r1 � s z\throttle_with_mapper_.<locals>.throttle_with_mapper.<locals>.subscribe.<locals>.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_.<locals>.throttle_with_mapper.<locals>.subscribe)Nr7 r8 �r> r: r" �throttle_with_mapperU s ��Dz3throttle_with_mapper_.<locals>.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" �<module> s � E� \
💾 Save Changes
❌ Cancel