U
vi4 @ s d dl mZmZmZmZmZmZ d dlZd dlmZm Z m Z d dl
m Z d dl m
Z
edZd
eee ee f ee je eee gee f ddd Zd gZdS ) )CallableIterableListOptionalTypeVarUnionN)
Observableabctyping)CompositeDisposable)default_comparer_T)secondcomparerreturnc sB |pt t| tr t| n| tt tt d fdd }|S )N)sourcer c s2 | dt jt tt j d fdd
}t|S )a< Determines whether two sequences are equal by comparing the
elements pairwise using a specified equality comparer.
Examples:
>>> res = sequence_equal([1,2,3])
>>> res = sequence_equal([{ "value": 42 }], lambda x, y: x.value == y.value)
>>> res = sequence_equal(reactivex.return_value(42))
>>> res = sequence_equal(
reactivex.return_value({ "value": 42 }),
lambda x, y: x.value == y.value
)
Args:
source: Source observable to compare.
Returns:
An observable sequence that contains a single element which
indicates whether both sequences are of equal length and their
corresponding elements are equal according to the specified
equality comparer.
N)observer schedulerc s dg dgg g t d dfdd }d d fdd }t d fd d
} fd d }j|j||d
}j|j||d
}t||S )NF)xr c
s t dkrpd}z || }W n2 tk
rV } z| W Y d S d }~X Y nX |sd n&d rd n
| d S Nr Flenpop Exceptionon_erroron_next on_completedappend)r vequale) comparer_donerr qlqr S/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_sequenceequal.pyon_next15 s
zLsequence_equal_..sequence_equal..subscribe..on_next1)r c sB d d< s>r$ d nd r> d d S NTr F)r r r% donelr" r r# r$ r% r&
on_completed1H s
zQsequence_equal_..sequence_equal..subscribe..on_completed1)r c
s t dkrpd}z || }W n2 tk
rV } z| W Y d S d }~X Y nX |sd n&d rd n
| d S r r )r r r exception)r! r* r r# r$ r% r& on_next2R s
zLsequence_equal_..sequence_equal..subscribe..on_next2c sJ dd< sFt dkr,d n d rFd d S r( )r r r r% r) r% r&
on_completed2e s
zQsequence_equal_..sequence_equal..subscribe..on_completed2)r )r
subscriber r )r r r' r+ r- r. Z
subscription1Z
subscription2)r! firstsecond_r) r& r/ , s*
z:sequence_equal_..sequence_equal..subscribe)N)r Z ObserverBaseboolr Z
SchedulerBaser )r r/ r! r1 )r0 r& sequence_equal s Kz'sequence_equal_..sequence_equal)r
isinstancer reactivex
from_iterabler r
r2 )r r r4 r% r3 r& sequence_equal_ s
er8 )N)r
r r r r r r r6 r r Zreactivex.disposabler Zreactivex.internalr r
ZComparerr2 r8 __all__r% r% r% r& s q