🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 14:19:39 | 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: _distinct.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZmZmZmZmZmZ d dlmZm Z m Z d dl m Z ed�Z ed�Z ee e e je d�dd�ZG d d � d ee �Zdee je e f ee je eee gee f d �d d�ZdgZd S )� )�Callable�Generic�List�Optional�TypeVar�cast)� Observable�abc�typing)�default_comparer�_T�_TKey)�array�item�comparerc C s( t | �D ]\}}|||�r| S qdS �N���)� enumerate)r r r �i�a� r �N/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_distinct.py�array_index_of_comparer s r c @ s. e Zd Zeje d�dd�Zed�dd�ZdS )�HashSet)r c C s || _ g | _d S �N)r �set)�selfr r r r �__init__ s zHashSet.__init__)�valuec C s( t | j|| j�dk}|r$| j�|� |S r )r r r �append)r r Z ret_valuer r r �push s z HashSet.pushN)�__name__� __module__� __qualname__r �Comparerr r r r r r r r s r N)� key_mapperr �returnc s6 |pt tjt t�� tt tt d�� �fdd� }|S )N)�sourcer& c s2 dt jt tt j t jd���� fdd� }t|�S )a^ Returns an observable sequence that contains only distinct elements according to the key_mapper and the comparer. Usage of this operator should be considered carefully due to the maintenance of an internal lookup structure which can grow large. Examples: >>> res = obs = distinct(source) Args: source: Source observable to return distinct items from. Returns: An observable sequence only containing the distinct elements, based on a computed key value, from the source sequence. N)�observer� schedulerr& c s6 t ��� td d�� ��fdd� }�j|�j�j|d�S )N)�xr& c sf t t| �}�rNz �| �}W n2 tk rL } z��|� W Y �d S d }~X Y nX � �|�rb��| � d S r )r r � Exception�on_errorr �on_next)r* �key�ex)�hashsetr% r( r r r- > s z?distinct_.<locals>.distinct.<locals>.subscribe.<locals>.on_next)r) )r r � subscriber, Z on_completed)r( r) r- )� comparer_r% r' )r0 r( r r1 8 s �z.distinct_.<locals>.distinct.<locals>.subscribe)N)r Z ObserverBaser r Z SchedulerBaseZDisposableBaser )r' r1 �r2 r% )r' r �distinct% s ��zdistinct_.<locals>.distinct)r r r$ r r r r )r% r r4 r r3 r � distinct_ s ,r5 )NN)r r r r r r r Z reactivexr r Zreactivex.internal.basicr r r r$ r r ZMapperr5 �__all__r r r r �<module> s" � � � 5
💾 Save Changes
❌ Cancel