Package rx.internal.operators
Class OperatorSequenceEqual
- java.lang.Object
-
- rx.internal.operators.OperatorSequenceEqual
-
public final class OperatorSequenceEqual extends java.lang.ObjectReturns anObservablethat emits a singleBooleanvalue that indicates whether two sourceObservables emit sequences of items that are equivalent to each other.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) static java.lang.ObjectLOCAL_ONCOMPLETEDNotificationLite doesn't work as zip uses it.
-
Constructor Summary
Constructors Modifier Constructor Description privateOperatorSequenceEqual()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description (package private) static <T> Observable<java.lang.Object>materializeLite(Observable<T> source)static <T> Observable<java.lang.Boolean>sequenceEqual(Observable<? extends T> first, Observable<? extends T> second, Func2<? super T,? super T,java.lang.Boolean> equality)Tests whether twoObservablesequences are identical, emittingtrueif both sequences complete without differing, andfalseif the two sequences diverge at any point.
-
-
-
Method Detail
-
materializeLite
static <T> Observable<java.lang.Object> materializeLite(Observable<T> source)
-
sequenceEqual
public static <T> Observable<java.lang.Boolean> sequenceEqual(Observable<? extends T> first, Observable<? extends T> second, Func2<? super T,? super T,java.lang.Boolean> equality)
Tests whether twoObservablesequences are identical, emittingtrueif both sequences complete without differing, andfalseif the two sequences diverge at any point.- Type Parameters:
T- the value type- Parameters:
first- the first of the twoObservables to comparesecond- the second of the twoObservables to compareequality- a function that tests emissions from eachObservablefor equality- Returns:
- an
Observablethat emitstrueiffirstandsecondcomplete after emitting equal sequences of items,falseif at any point in their sequences the twoObservables emit a non-equal item.
-
-