🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 14:20:41 | 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: _groupbyuntil.cpython-38.pyc
Read Only
U v�i� � @ s d dl mZ d dlmZmZmZmZmZ d dlm Z m Z m Z d dlm Z d dlmZmZmZ d dlmZ d dlmZ d dlmZ ed �Zed �Zed �Zdeeef eeeef ee eef ge e f eeg ee f ee e ge e eef f d �dd�ZdgZ d S )� )� OrderedDict)�Any�Callable�Optional�TypeVar�cast)�GroupedObservable� Observable�abc)� operators)�CompositeDisposable�RefCountDisposable�SingleAssignmentDisposable)�identity��Subject)�Mapper�_T�_TKey�_TValueN)� key_mapper�element_mapper�duration_mapper�subject_mapper�returnc sT |pt tttf t��dd� }|p$|�tt ttttf d�� ���fdd� }|S )aQ Groups the elements of an observable sequence according to a specified key mapper function. A duration mapper function is used to control the lifetime of groups. When a group expires, it receives an OnCompleted notification. When a new element with the same key value as a reclaimed group occurs, the group will be reborn with a new lifetime request. Examples: >>> group_by_until(lambda x: x.id, None, lambda : reactivex.never()) >>> group_by_until( lambda x: x.id,lambda x: x.name, lambda grp: reactivex.never() ) >>> group_by_until( lambda x: x.id, lambda x: x.name, lambda grp: reactivex.never(), lambda: ReplaySubject() ) Args: key_mapper: A function to extract the key for each element. duration_mapper: A function to signal the expiration of a group. subject_mapper: A function that returns a subject used to initiate a grouped observable. Default mapper returns a Subject object. Returns: a sequence of observable groups, each of which corresponds to a unique key value, containing all elements that share that same key value. If a group's lifetime expires, a new group with the same key value can be created once an element with such a key value is encountered. c S s t � S �Nr � r r �R/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_groupbyuntil.py�<lambda>< � z!group_by_until_.<locals>.<lambda>)�sourcer c s> dt jtttf tt j t jd����� �fdd� }t|�S )N)�observer� schedulerr c s~ t � �t� � t� ��td d���� ����� �f dd� }td d���fdd� }d d���fdd � }� ��j|||�d �� �S ) N)�xr c sB d �d �z �| ��W nJ t k r^ } z,� �� D ]}|�|� q.��|� W Y �d S d }~X Y nX d}� �����s�z � � �W nJ t k r� } z,� �� D ]}|�|� q���|� W Y �d S d }~X Y nX �� �< d}|�r�t��� �}t���}z �|�}W nN t k �rJ } z.� �� D ]}|�|� �q��|� W Y �d S d }~X Y nX ��|� t� ����� d d������ fdd� � td d�dd�}t d d ��� fd d � }d d�� fd d � } |� t � d��j ||| � d��_ z �| �} W nN t k �r2 } z.� �� D ]}|�| � �q ��| � W Y �d S d } ~ X Y nX ��| � d S )NFT�r c s$ �� r��= �� � � ��� d S r )� on_completed�remover )�group_disposable�key�sad�writer�writersr r �expirez s z[group_by_until_.<locals>.group_by_until.<locals>.subscribe.<locals>.on_next.<locals>.expire)�valuer c S s d S r r )r- r r r �on_next� s z\group_by_until_.<locals>.group_by_until.<locals>.subscribe.<locals>.on_next.<locals>.on_next)�exnr c s& �� � D ]}|�| � q� �| � d S r ��values�on_error)r/ �wrt�r! r+ r r r2 � s z]group_by_until_.<locals>.group_by_until.<locals>.subscribe.<locals>.on_next.<locals>.on_errorc s � � d S r r r )r, r r r% � s zagroup_by_until_.<locals>.group_by_until.<locals>.subscribe.<locals>.on_next.<locals>.on_completed� �r" )� Exceptionr1 r2 �getr r. r �addr �pipe�opsZtake� subscribeZ disposable) r# �er3 Zfire_new_map_entry�groupZduration_group�durationr. r2 r% �element�error) r �element_mapper_r' r r! �ref_count_disposabler" �subject_mapper_r+ )r, r( r) r* r r. J sz � � � � zKgroup_by_until_.<locals>.group_by_until.<locals>.subscribe.<locals>.on_next)�exr c s& �� � D ]}|�| � q� �| � d S r r0 )rE r3 r4 r r r2 � s zLgroup_by_until_.<locals>.group_by_until.<locals>.subscribe.<locals>.on_errorr$ c s" �� � D ] } | �� q� �� d S r )r1 r% )r3 r4 r r r% � s zPgroup_by_until_.<locals>.group_by_until.<locals>.subscribe.<locals>.on_completedr6 )r r r r r7 r9 r< )r! r" r. r2 r% )r rB r r rD )r' r! rC r" r+ r r< B s $Q�z:group_by_until_.<locals>.group_by_until.<locals>.subscribe)N) r Z ObserverBaser r r r Z SchedulerBaseZDisposableBaser )r r< �r rB r rD )r r �group_by_until? s ��jz'group_by_until_.<locals>.group_by_until)r r r r r r r r )r r r r Zdefault_subject_mapperrG r rF r �group_by_until_ s &�orH )N) � collectionsr �typingr r r r r Z reactivexr r r r r; Zreactivex.disposabler r r Zreactivex.internal.basicr Zreactivex.subjectr Zreactivex.typingr r r r rH �__all__r r r r �<module> s( � �
💾 Save Changes
❌ Cancel