Package rx.internal.operators

Class OperatorSequenceEqual

java.lang.Object

rx.internal.operators.OperatorSequenceEqual

public final class OperatorSequenceEqual
extends Object

Returns an Observable that emits a single Boolean value that indicates whether two source Observables emit sequences of items that are equivalent to each other.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final Object	LOCAL_ONCOMPLETED	NotificationLite doesn't work as zip uses it.

Constructor Summary

Constructors

Modifier	Constructor	Description
private	OperatorSequenceEqual()

Method Summary

Modifier and Type	Method	Description
(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 two Observable sequences are identical, emitting true if both sequences complete without differing, and false if the two sequences diverge at any point.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOCAL_ONCOMPLETED

static final Object LOCAL_ONCOMPLETED

NotificationLite doesn't work as zip uses it.

Constructor Details

OperatorSequenceEqual

private OperatorSequenceEqual()

Method Details

materializeLite

static <T> Observable<Object> materializeLite(Observable<T> source)

sequenceEqual

public static <T> Observable<Boolean> sequenceEqual(Observable<? extends T> first,
 Observable<? extends T> second,
 Func2<? super T,? super T,Boolean> equality)

Tests whether two Observable sequences are identical, emitting true if both sequences complete without differing, and false if the two sequences diverge at any point.

Type Parameters:

T - the value type

Parameters:

first - the first of the two Observables to compare

second - the second of the two Observables to compare

equality - a function that tests emissions from each Observable for equality

Returns:

an Observable that emits true if first and second complete after emitting equal sequences of items, false if at any point in their sequences the two Observables emit a non-equal item.