U
vi @ s d dl mZmZmZmZmZmZ d dlmZm Z m Z d dl
m Z edZ edZ
ee
e
e je
dddZG d d
d
ee
Zdee je e
f ee je
eee gee f d d
dZdgZd S ) )CallableGenericListOptionalTypeVarcast)
Observableabctyping)default_comparer_T_TKey)arrayitemcomparerc C s( t | D ]\}}|||r| S qdS N) enumerate)r r r ia r N/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_distinct.pyarray_index_of_comparer
s
r c @ s. e Zd Zeje dddZedddZdS )HashSet)r c C s || _ g | _d S N)r set)selfr r r r __init__ s zHashSet.__init__)valuec C s( t | j|| jdk}|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|jj|dS )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
Exceptionon_errorr on_next)r* keyex)hashsetr% r( r r r- > s
z?distinct_..distinct..subscribe..on_next)r) )r r subscriber, Z on_completed)r( r) r- ) comparer_r% r' )r0 r( r r1 8 s
z.distinct_..distinct..subscribe)N)r Z ObserverBaser r Z
SchedulerBaseZDisposableBaser )r' r1 r2 r% )r' r distinct% s zdistinct_..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 s"
5