🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:23:54 | 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: _groupjoin.cpython-38.pyc
Read Only
U v�i� � @ s� d dl Z d dlmZ d dlmZmZmZmZmZ d dl m Z m Z d dl m Z d dlmZmZmZ d dlmZ d dlmZ ed �Zed �Ze �d �Ze e eege e f eege e f ee e ge eee e f f d �d d�ZdgZdS )� N)� OrderedDict)�Any�Callable�Optional�Tuple�TypeVar)� Observable�abc)� operators)�CompositeDisposable�RefCountDisposable�SingleAssignmentDisposable)�add_ref)�Subject�_TLeft�_TRightZRx)�right�left_duration_mapper�right_duration_mapper�returnc sB t dd�dd��tt ttttt f d�� ���fdd� }|S )a� Correlates the elements of two sequences based on overlapping durations, and groups the results. Args: right: The right observable sequence to join elements for. left_duration_mapper: A function to select the duration (expressed as an observable sequence) of each element of the left observable sequence, used to determine overlap. right_duration_mapper: A function to select the duration (expressed as an observable sequence) of each element of the right observable sequence, used to determine overlap. Returns: An observable sequence that contains elements combined into a tuple from source elements that have an overlapping duration. N)�_r c S s d S �N� )r r r �O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_groupjoin.py�nothing+ s z group_join_.<locals>.nothing)�leftr c sB dt jtttt f tt j t jd�� ����fdd� }t|�S )N)�observer� schedulerr c s� t � � t� ��t� �t� �dg�dg�td d�� �� ��� ����f dd� }td d���fdd� }� ��j||�j�d�� td d�� ��� �� ���f d d � }td d���fd d � }� �� j||�d�� �S ) Nr )�valuer c s� t � ��j�& �d � �d d7 < ��� < W 5 Q R X z| t�� �f}W nX tk r� } z:t�d| � ��� D ]}|�|� qr� �|� W Y �d S d }~X Y nX � �|� � �� D ]}��|� q�t � ��� �� � ����fdd�}z �| �}W nN tk �rD } z.��� D ]}|�|� �q� �|� W Y �d S d }~X Y nX tt d��� fdd� }|� t �d��j�||� d ��_d S ) Nr � z*** Exception: %sc s$ � �kr�� = �� � ���� d S r )� on_completed�remover )�_id�group�left_map�md�subjectr r �expireV s zXgroup_join_.<locals>.group_join.<locals>.subscribe.<locals>.on_next_left.<locals>.expire��errorr c s& � � � D ]}|�| � q��| � d S r ��values�on_error�r) � left_value�r$ r r r r, f s zZgroup_join_.<locals>.group_join.<locals>.subscribe.<locals>.on_next_left.<locals>.on_error�r )r �lockr � Exception�logr) r+ r, �on_nextr �addr �pipe�ops�take� subscribe� disposable)r �result�er. Z right_valuer' �durationr, ) r# r r �left_idr$ r r �rcd� right_mapr )r" r% r& r � on_next_left< sB �zHgroup_join_.<locals>.group_join.<locals>.subscribe.<locals>.on_next_leftr( c s& � � � D ]}|�| � q��| � d S r r* r- r/ r r � on_error_leftp s zIgroup_join_.<locals>.group_join.<locals>.subscribe.<locals>.on_error_leftr0 c s �j �& �d � �d d7 < | � � < W 5 Q R X t� ����� � ��� fdd�}z �| �}W nJ tk r� } z,��� D ]}|�|� qz��|� W Y �d S d }~X Y nX td����fdd� }|�t�d��j �||� d��_ �j � ��� D ]}|� | � q�W 5 Q R X d S ) Nr r c s �� = �� �� d S r )r! r )r" r# r% r@ r r r' � s zVgroup_join_.<locals>.group_join.<locals>.subscribe.<locals>.send_right.<locals>.expire)r) c s8 � j �( ��� D ]}|�| � q��| � W 5 Q R X d S r )r1 r+ r, r- )r r$ r r r r, � s zXgroup_join_.<locals>.group_join.<locals>.subscribe.<locals>.send_right.<locals>.on_errorr0 ) r1 r r5 r2 r+ r, r6 r7 r8 r9 r: r4 )r r' r= r< r. r, ) r# r r$ r r r �right_idr@ r )r" r% r � send_right s0 � zFgroup_join_.<locals>.group_join.<locals>.subscribe.<locals>.send_rightc s& � � � D ]}|�| � q��| � d S r r* r- r/ r r �on_error_right� s zJgroup_join_.<locals>.group_join.<locals>.subscribe.<locals>.on_error_right) r r r r r2 r5 r9 r r )r r rA rB rD rE )r r r r r )r# r> r$ r r? rC r@ r r r9 1 s( &4�� $%z2group_join_.<locals>.group_join.<locals>.subscribe)N) r Z ObserverBaser r r r r Z SchedulerBaseZDisposableBase)r r9 �r r r r )r r � group_join. s ��|z group_join_.<locals>.group_join)r r r r r )r r r rG r rF r � group_join_ s � rH ) �logging� collectionsr �typingr r r r r Z reactivexr r r r7 Zreactivex.disposabler r r Zreactivex.internalr Zreactivex.subjectr r r � getLoggerr3 rH �__all__r r r r �<module> s" �
💾 Save Changes
❌ Cancel