🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 21:30:40 | PHP 8.2.33
📂
/ (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: _windowwithcount.cpython-38.pyc
Read Only
U v�i� � @ s� d dl Z d dlmZmZmZmZ d dlmZmZ d dl m Z m Z d dl m Z mZ d dlmZ e �d�Zed�Zd eee eee geee f d �d d �Zd gZdS ) � N)�Callable�List�Optional�TypeVar)� Observable�abc)�RefCountDisposable�SingleAssignmentDisposable)�ArgumentOutOfRangeException�add_ref)�SubjectZRx�_T)�count�skip�returnc sR � dkrt � �|dk r|n� ��dkr,t � �tt ttt d�� �fdd� }|S )a� Projects each element of an observable sequence into zero or more windows which are produced based on element count information. Examples: >>> window_with_count(10) >>> window_with_count(10, 1) Args: count: Length of each window. skip: [Optional] Number of elements to skip between creation of consecutive windows. If not specified, defaults to the count. Returns: An observable sequence of windows. r N)�sourcer c s2 dt jtt tt j d���� fdd� }t|�S )N)�observer� schedulerc s� t � }t|��dg�g ����fdd�� � � td d��� ���fdd� }td d���fdd � }d d ���fd d � }�j||||d �|_�S )Nr c s$ t � } ��| � � �t| ��� d S )N)r �append�on_nextr )�s)r �q�refCountDisposable� �U/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_windowwithcount.py� create_window4 s zWwindow_with_count_.<locals>.window_with_count.<locals>.subscribe.<locals>.create_window)�xr c st �D ]}|� | � q�d � d }|dkrJ|� dkrJ��d�}|�� �d d7 < �d � dkrp�� d S )Nr � )r �pop� on_completed)r �item�cr )r r �nr �skip_r r r ; s zQwindow_with_count_.<locals>.window_with_count.<locals>.subscribe.<locals>.on_next)� exceptionr c s$ �r�� d��| � q � �| � d S �Nr )r �on_error)r$ �r r r r r& H s zRwindow_with_count_.<locals>.window_with_count.<locals>.subscribe.<locals>.on_error)r c s �r�� d��� q � �� d S r% )r r r r' r r r M s zVwindow_with_count_.<locals>.window_with_count.<locals>.subscribe.<locals>.on_completed)r )r r r � Exception� subscribeZ disposable)r r �mr r& r )r r# r )r r" r r r r r) + s �z@window_with_count_.<locals>.window_with_count.<locals>.subscribe)N)r Z ObserverBaser r r Z SchedulerBase)r r) �r r# )r r �window_with_count* s � �,z-window_with_count_.<locals>.window_with_count)r r r )r r r, r r+ r �window_with_count_ s "/r- )N)�logging�typingr r r r Z reactivexr r Zreactivex.disposabler r Zreactivex.internalr r Zreactivex.subjectr � getLogger�logr �intr- �__all__r r r r �<module> s � � N
💾 Save Changes
❌ Cancel