Package rx.internal.operators
Class OperatorDistinctUntilChanged<T,U>
java.lang.Object
rx.internal.operators.OperatorDistinctUntilChanged<T,U>
- Type Parameters:
T
- the value typeU
- the key type
- All Implemented Interfaces:
Func1<Subscriber<? super T>,
,Subscriber<? super T>> Func2<U,
,U, Boolean> Function
,Observable.Operator<T,
T>
public final class OperatorDistinctUntilChanged<T,U>
extends Object
implements Observable.Operator<T,T>, Func2<U,U,Boolean>
Returns an Observable that emits all sequentially distinct items emitted by the source.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescription -
Constructor Summary
ConstructorsConstructorDescriptionOperatorDistinctUntilChanged
(Func1<? super T, ? extends U> keySelector) OperatorDistinctUntilChanged
(Func2<? super U, ? super U, Boolean> comparator) -
Method Summary
Modifier and TypeMethodDescriptionSubscriber
<? super T> call
(Subscriber<? super T> child) static <T> OperatorDistinctUntilChanged
<T, T> instance()
Returns a singleton instance of OperatorDistinctUntilChanged that was built using the identity function for comparison (new OperatorDistinctUntilChanged(UtilityFunctions.identity())
).
-
Field Details
-
keySelector
-
comparator
-
-
Constructor Details
-
OperatorDistinctUntilChanged
-
OperatorDistinctUntilChanged
-
-
Method Details
-
instance
Returns a singleton instance of OperatorDistinctUntilChanged that was built using the identity function for comparison (new OperatorDistinctUntilChanged(UtilityFunctions.identity())
).- Type Parameters:
T
- the value type- Returns:
- Operator that emits sequentially distinct values only using the identity function for comparison
-
call
-
call
-