Package rx.internal.operators
Class OperatorSequenceEqual
java.lang.Object
rx.internal.operators.OperatorSequenceEqual
Returns an
Observable
that emits a single Boolean
value that indicates whether two source
Observable
s emit sequences of items that are equivalent to each other.-
Field Summary
FieldsModifier and TypeFieldDescription(package private) static final Object
NotificationLite doesn't work as zip uses it. -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) static <T> Observable
<Object> materializeLite
(Observable<T> source) static <T> Observable
<Boolean> sequenceEqual
(Observable<? extends T> first, Observable<? extends T> second, Func2<? super T, ? super T, Boolean> equality) Tests whether twoObservable
sequences are identical, emittingtrue
if both sequences complete without differing, andfalse
if the two sequences diverge at any point.
-
Field Details
-
LOCAL_ONCOMPLETED
NotificationLite doesn't work as zip uses it.
-
-
Constructor Details
-
OperatorSequenceEqual
private OperatorSequenceEqual()
-
-
Method Details
-
materializeLite
-
sequenceEqual
public static <T> Observable<Boolean> sequenceEqual(Observable<? extends T> first, Observable<? extends T> second, Func2<? super T, ? super T, Boolean> equality) Tests whether twoObservable
sequences are identical, emittingtrue
if both sequences complete without differing, andfalse
if the two sequences diverge at any point.- Type Parameters:
T
- the value type- Parameters:
first
- the first of the twoObservable
s to comparesecond
- the second of the twoObservable
s to compareequality
- a function that tests emissions from eachObservable
for equality- Returns:
- an
Observable
that emitstrue
iffirst
andsecond
complete after emitting equal sequences of items,false
if at any point in their sequences the twoObservable
s emit a non-equal item.
-