🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 16:51:37 | 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: _windowwithtimeorcount.cpython-38.pyc
Read Only
U v�i) � @ s� d dl mZmZmZmZ d dlmZmZm Z d dlm Z m Z m Z m Z d dl mZ d dlmZ d dlmZ ed�Zd e jeeej eee geee f d �d d �Zd gZdS ) � )�Any�Callable�Optional�TypeVar)� Observable�abc�typing)�CompositeDisposable�RefCountDisposable�SerialDisposable�SingleAssignmentDisposable)�add_ref)�TimeoutScheduler)�Subject�_TN)�timespan�count� scheduler�returnc s( t t t t t d�� ��fdd� }|S )N)�sourcer c s8 dt jtt tt j t jd���� �fdd� }t|�S )N)�observer� scheduler_r c s� � p|pt �� � d�t� �t� �d�t��}t|��td�� ������� �f dd� ���t���� �d� t d d��������fdd� }t d d���fd d � }d d ���fd d � }|� � j ||||d�� �S )Nr ��_idc sB t � }|�_dtjtd�� ������ fdd� }���|�|_d S )N)r �statec sF � �kr d S d��d7 ��}�� � t� ���t���� �|� d S )Nr � )� on_completedr �on_nextr )r r �new_id)r � create_timer�nr �ref_count_disposable�s� window_id� �[/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_windowwithtimeorcount.py�action) s zvwindow_with_time_or_count_.<locals>.window_with_time_or_count.<locals>.subscribe.<locals>.create_timer.<locals>.action)N)r Z disposabler � SchedulerBaser Zschedule_relative)r �mr& ) � _schedulerr r r r! r" �timer_dr r# r r% r $ s $ zfwindow_with_time_or_count_.<locals>.window_with_time_or_count.<locals>.subscribe.<locals>.create_timer)�xr c sd d}d}�� | � �d7 ��� krTd}d��d7 ��}��� t� ��� t���� |r`�|� d S )NFr r T)r r r r )r+ Z new_windowr )r r r r r! r" r# r$ r% r ; s zawindow_with_time_or_count_.<locals>.window_with_time_or_count.<locals>.subscribe.<locals>.on_next)�er c s �� | � � � | � d S �N)�on_error)r, �r r" r$ r% r. N s zbwindow_with_time_or_count_.<locals>.window_with_time_or_count.<locals>.subscribe.<locals>.on_error)r c s �� � � � � d S r- )r r$ r/ r$ r% r R s zfwindow_with_time_or_count_.<locals>.window_with_time_or_count.<locals>.subscribe.<locals>.on_completed)r ) r Z singletonr r r r �intr r r � Exception�add� subscribe)r r Zgroup_disposabler r. r )r r r r )r) r r r r! r" r* r# r% r3 s" " �zPwindow_with_time_or_count_.<locals>.window_with_time_or_count.<locals>.subscribe)N)r Z ObserverBaser r r r' ZDisposableBase)r r3 �r r r )r r% �window_with_time_or_count s � �Dz=window_with_time_or_count_.<locals>.window_with_time_or_count)r r )r r r r5 r$ r4 r% �window_with_time_or_count_ s $Gr6 )N)r r r r r Z reactivexr r Zreactivex.disposabler r r r Zreactivex.internalr Zreactivex.schedulerr Zreactivex.subjectr r Z RelativeTimer0 r' r6 �__all__r$ r$ r$ r% �<module> s �� O
💾 Save Changes
❌ Cancel