Package rx.internal.operators
Class OperatorMapPair<T,U,R>
java.lang.Object
rx.internal.operators.OperatorMapPair<T,U,R>
- Type Parameters:
T
- the type of items emitted by the sourceObservable
U
- the type of items emitted by the derivedObservable
sR
- the type of items to be emitted by thisOperator
- All Implemented Interfaces:
Func1<Subscriber<? super Observable<? extends R>>,
,Subscriber<? super T>> Function
,Observable.Operator<Observable<? extends R>,
T>
public final class OperatorMapPair<T,U,R>
extends Object
implements Observable.Operator<Observable<? extends R>,T>
An
Observable.Operator
that pairs up items emitted by a source Observable
with the sequence of items
emitted by the Observable
that is derived from each item by means of a selector, and emits the
results of this pairing.-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final Func1
<? super T, ? extends Observable<? extends U>> -
Constructor Summary
ConstructorsConstructorDescriptionOperatorMapPair
(Func1<? super T, ? extends Observable<? extends U>> collectionSelector, Func2<? super T, ? super U, ? extends R> resultSelector) -
Method Summary
Modifier and TypeMethodDescriptionSubscriber
<? super T> call
(Subscriber<? super Observable<? extends R>> o) static <T,
U> Func1 <T, Observable<U>> convertSelector
(Func1<? super T, ? extends Iterable<? extends U>> selector) Creates the function that generates aObservable
based on an item emitted by anotherObservable
.
-
Field Details
-
collectionSelector
-
resultSelector
-
-
Constructor Details
-
OperatorMapPair
-
-
Method Details
-
convertSelector
public static <T,U> Func1<T,Observable<U>> convertSelector(Func1<? super T, ? extends Iterable<? extends U>> selector) Creates the function that generates aObservable
based on an item emitted by anotherObservable
.- Type Parameters:
T
- the input value typeU
- the value type of the generated Observable- Parameters:
selector
- a function that accepts an item and returns anIterable
of corresponding items- Returns:
- a function that converts an item emitted by the source
Observable
into anObservable
that emits the items generated byselector
operating on that item
-
call
-