U
vi5 @ s d dl mZmZmZmZ d dlmZmZ d dlm Z m
Z
d dl m Z m
Z
edZedZd ee
eef ee e eee gee f dd d
Zd
gZdS ) )CallableOptionalTypeVarcast)
Observableabc)default_compareridentity)ComparerMapper_T_TKeyN)
key_mappercomparerreturnc sB | pt ttgtf t|p t tt tt d fdd }|S )N)sourcer c s2 dt jt tt j t jd fdd
}t|S )ay Returns an observable sequence that contains only distinct
contiguous elements according to the key_mapper and the
comparer.
Examples:
>>> op = distinct_until_changed();
>>> op = distinct_until_changed(lambda x: x.id)
>>> op = distinct_until_changed(lambda x: x.id, lambda x, y: x == y)
Args:
key_mapper: [Optional] A function to compute the comparison
key for each element. If not provided, it projects the
value.
comparer: [Optional] Equality comparer for computed key
values. If not provided, defaults to an equality
comparer function.
Returns:
An observable sequence only containing the distinct
contiguous elements, based on a computed key value, from
the source sequence.
N)observer schedulerr c s@ dt td td d fdd }j|jj|dS )NF)valuer c
s d}z | }W n2 t k
rB } z| W Y d S d }~X Y nX rz |}W n2 t k
r } z| W Y d S d }~X Y nX r|sd|| d S )NFT) Exceptionon_erroron_next)r Zcomparer_equalskey exception) comparer_ current_keyhas_current_key key_mapper_r Z/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_distinctuntilchanged.pyr 2 s
z[distinct_until_changed_..distinct_until_changed..subscribe..on_next)r )r r
r subscriber Z on_completed)r r r )r r r )r r r r r + s
zJdistinct_until_changed_..distinct_until_changed..subscribe)N)r Z ObserverBaser r Z
SchedulerBaseZDisposableBaser )r r r r )r r distinct_until_changed s z7distinct_until_changed_..distinct_until_changed)r r r r
r r r )r r r" r r! r distinct_until_changed_ s :r# )NN)typingr r r r Z reactivexr r Zreactivex.internal.basicr r Zreactivex.typingr
r r r
r# __all__r r r r s
E