🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:16:36 | 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: _buffer.cpython-38.pyc
Read Only
U v�i� � @ s d dl mZmZmZmZmZ d dlmZmZ d dlm Z ed�Z ee eee geee f d�dd�Z eg ee f eee geee f d�d d �Z ee eegee f eee geee f d �d d �Zdeee eee geee f d�dd�Zddd d gZdS )� )�Any�Callable�List�Optional�TypeVar)� Observable�compose)� operators�_T)� boundaries�returnc C s t t�| �t�t�� ��S �N)r �opsZwindow�flat_map�to_list)r � r �L/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_buffer.py�buffer_ s �r )�closing_mapperr c C s t t�| �t�t�� ��S r )r r Z window_whenr r )r r r r � buffer_when_ s �r )�openingsr r c C s t t�| |�t�t�� ��S r )r r Z window_toggler r )r r r r r �buffer_toggle_ s �r N)�count�skipr c s& t t t tt d�� �fdd� }|S )a9 Projects each element of an observable sequence into zero or more buffers which are produced based on element count information. Examples: >>> res = buffer_with_count(10)(xs) >>> res = buffer_with_count(10, 1)(xs) Args: count: Length of each buffer. skip: [Optional] Number of elements to skip between creation of consecutive buffers. If not provided, defaults to the count. Returns: A function that takes an observable source and returns an observable sequence of buffers. )�sourcer c s^ �d kr � �t t t tt d�dd�}tt td�dd�}| �t�� ��t�|�t�|��S )N)�valuer c S s | � t�� �S r )�piper r �r r r r �mapper? s �z=buffer_with_count_.<locals>.buffer_with_count.<locals>.mapperc S s t | �dkS )Nr )�lenr r r r � predicateD s z@buffer_with_count_.<locals>.buffer_with_count.<locals>.predicate) r r r �boolr r Zwindow_with_countr �filter)r r r �r r r r �buffer_with_count9 s �z-buffer_with_count_.<locals>.buffer_with_count)r r r )r r r$ r r# r �buffer_with_count_$ s "r% )N)�typingr r r r r Z reactivexr r r r r r r r �intr% �__all__r r r r �<module> s( � � � � � ,
💾 Save Changes
❌ Cancel