🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:25:49 | 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: _window.cpython-38.pyc
Read Only
U v�i8 � @ s. d dl Z d dlmZmZmZmZmZ d dlmZm Z m Z d dlm Z d dl mZmZmZmZ d dlmZmZ d dlmZ e �d�Zed �Zee eegee f eee geee f d �d d �Zee eee geee f d �dd�Zeg ee f eee geee f d�dd�Z ddd gZ dS )� N)�Any�Callable�Optional�Tuple�TypeVar)� Observable�abc�empty)� operators)�CompositeDisposable�RefCountDisposable�SerialDisposable�SingleAssignmentDisposable)�add_ref�noop)�SubjectZRx�_T)�openings�closing_mapper�returnc s& t t t t t d�� �fdd� }|S )��Projects each element of an observable sequence into zero or more windows. Args: source: Source observable to project into windows. Returns: An observable sequence of windows. ��sourcer c s: t ttt f d�dd�}��t�| � dd� �t�|��S )N)�argsc S s | \}}|S �N� )r �_�windowr r �L/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_window.py�mapper" s z5window_toggle_.<locals>.window_toggle.<locals>.mapperc S s t � S r )r )r r r r �<lambda>* � z7window_toggle_.<locals>.window_toggle.<locals>.<lambda>)r r r r �pipe�opsZ group_join�map)r r �r r r r � window_toggle! s ��z%window_toggle_.<locals>.window_toggle�r r )r r r& r r% r �window_toggle_ s "r( )� boundariesr c s$ t t t t t d�� fdd� }|S )r r c s4 dt jtt tt j t jd��� fdd� }t|�S )N)�observer� schedulerr c s� t � �t� }t|��� �t���� td d��fdd� }td d�� �fdd� }d d�� �fdd � }|��j||||d �� t t d �� ��fd d � }|��j||||d �� �S )N)�xr c s � � | � d S r ��on_next)r, )�window_subjectr r �on_next_windowJ s zBwindow_.<locals>.window.<locals>.subscribe.<locals>.on_next_window)�errr c s �� | � � � | � d S r ��on_error)r1 �r* r/ r r r3 M s z<window_.<locals>.window.<locals>.subscribe.<locals>.on_error�r c s �� � � � � d S r �� on_completedr r4 r r r7 Q s z@window_.<locals>.window.<locals>.subscribe.<locals>.on_completed�r+ ��wc s" �� � t� �� �t���� d S r �r7 r r. r r9 �r* �rr/ r r �on_next_observer[ s zDwindow_.<locals>.window.<locals>.subscribe.<locals>.on_next_observer) r r r r. r r � Exception�add� subscriber )r* r+ �dr0 r3 r7 r> )r) r r< r rA @ s2 �� ��z*window_.<locals>.window.<locals>.subscribe)N)r � ObserverBaser r r � SchedulerBaseZDisposableBase�r rA �r) �r r r ? s � �(zwindow_.<locals>.windowr' )r) r r rF r �window_2 s +rH )r r c s$ t t t t t d�� fdd� }|S )r r c s0 dt jtt tt j d��� fdd� }t|�S )N)r* r+ c s� t � �t��}t|��t� ���t���� td d��fdd� }td d���fdd� �d d���fdd � }|��j |�|�d �� �� ������fd d �� � � �S ) N)�valuer c s � � | � d S r r- )rI )r r r r. � s zEwindow_when_.<locals>.window_when.<locals>.subscribe.<locals>.on_next)�errorr c s �� | � � � | � d S r r2 )rJ �r* r r r r3 � s zFwindow_when_.<locals>.window_when.<locals>.subscribe.<locals>.on_errorr5 c s �� � � � � d S r r6 r rK r r r7 � s zJwindow_when_.<locals>.window_when.<locals>.subscribe.<locals>.on_completedr8 c s� z � � } W n2 t k r< } z��|� W Y �d S d }~X Y nX ����fdd�}t� }|�_| �t�d��jt�|�d�|_d S )Nc s( �� � t� ���t���� � � d S r r; r )�create_window_on_completedr* r= r r r r7 � s znwindow_when_.<locals>.window_when.<locals>.subscribe.<locals>.create_window_on_completed.<locals>.on_completed� r8 ) r? r3 r Z disposabler" r# ZtakerA r )Z window_close� exceptionr7 �m1)r rL �mr* r3 r= r+ r r r rL � s �zXwindow_when_.<locals>.window_when.<locals>.subscribe.<locals>.create_window_on_completed) r r r r r. r r r? r@ rA )r* r+ rB r. r7 )r r )rL rP r* r3 r= r+ r r rA { s �z4window_when_.<locals>.window_when.<locals>.subscribe)N)r rC r r r rD rE �r rG r � window_whenz s � �1z!window_when_.<locals>.window_whenr' )r rR r rQ r � window_when_m s 4rS ) �logging�typingr r r r r Z reactivexr r r r r# Zreactivex.disposabler r r r Zreactivex.internalr r Zreactivex.subjectr � getLogger�logr r( rH rS �__all__r r r r �<module> s& � � <� D
💾 Save Changes
❌ Cancel