🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:29:17 | 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: _pairwise.cpython-38.pyc
Read Only
U v�i� � @ sf d dl mZmZmZmZmZ d dlmZmZ ed�Z eee geee e f f d�dd�Z dgZ dS )� )�Callable�Optional�Tuple�TypeVar�cast)� Observable�abc�_T)�returnc C s$ t t t tttf d�dd�} | S )N)�sourcer c s6 dt jtttf tt j t jd�� fdd� }t|�S )a3 Partially applied pairwise operator. Returns a new observable that triggers on the second and subsequent triggerings of the input observable. The Nth triggering of the input observable passes the arguments from the N-1th and Nth triggering as a pair. The argument passed to the N-1th triggering is held in hidden internal state until the Nth triggering occurs. Returns: An observable that triggers on successive pairs of observations from the input observable as an array. N)�observer� schedulerr c s: d� t td ��td d�� ���fdd� }��|�j�j�S )NF)�xr c s> d }�j � � r�| f}nd� | �W 5 Q R X |r:��|� d S )NT)�lock�on_next)r �pair)� has_previousr �previousr � �N/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_pairwise.pyr s z?pairwise_.<locals>.pairwise.<locals>.subscribe.<locals>.on_next)r r � subscribeZon_errorZ on_completed)r r r �r )r r r r r s z.pairwise_.<locals>.pairwise.<locals>.subscribe)N)r Z ObserverBaser r r Z SchedulerBaseZDisposableBaser )r r r r r �pairwise s ��zpairwise_.<locals>.pairwise)r r r )r r r r � pairwise_ s )r N) �typingr r r r r Z reactivexr r r r �__all__r r r r �<module> s (-
💾 Save Changes
❌ Cancel