Package rx.internal.operators
Class OperatorToObservableSortedList<T>
- java.lang.Object
-
- rx.internal.operators.OperatorToObservableSortedList<T>
-
- Type Parameters:
T
- the type of the items emitted by the source and the resultingObservable
s
- All Implemented Interfaces:
Func1<Subscriber<? super java.util.List<T>>,Subscriber<? super T>>
,Function
,Observable.Operator<java.util.List<T>,T>
public final class OperatorToObservableSortedList<T> extends java.lang.Object implements Observable.Operator<java.util.List<T>,T>
Return anObservable
that emits the items emitted by the sourceObservable
, in a sorted order (each item emitted by theObservable
must implementComparable
with respect to all other items in the sequence, or you must pass in a sort function).
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
OperatorToObservableSortedList.DefaultComparableFunction
-
Field Summary
Fields Modifier and Type Field Description private static java.util.Comparator
DEFAULT_SORT_FUNCTION
(package private) int
initialCapacity
(package private) java.util.Comparator<? super T>
sortFunction
-
Constructor Summary
Constructors Constructor Description OperatorToObservableSortedList(int initialCapacity)
OperatorToObservableSortedList(Func2<? super T,? super T,java.lang.Integer> sortFunction, int initialCapacity)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Subscriber<? super T>
call(Subscriber<? super java.util.List<T>> child)
-
-
-
Field Detail
-
sortFunction
final java.util.Comparator<? super T> sortFunction
-
initialCapacity
final int initialCapacity
-
DEFAULT_SORT_FUNCTION
private static final java.util.Comparator DEFAULT_SORT_FUNCTION
-
-
Method Detail
-
call
public Subscriber<? super T> call(Subscriber<? super java.util.List<T>> child)
- Specified by:
call
in interfaceFunc1<Subscriber<? super java.util.List<T>>,Subscriber<? super T>>
-
-