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 java.lang.Object implements Observable.Operator<Observable<? extends R>,T>
AnObservable.Operator
that pairs up items emitted by a sourceObservable
with the sequence of items emitted by theObservable
that is derived from each item by means of a selector, and emits the results of this pairing.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
OperatorMapPair.MapPairSubscriber<T,U,R>
(package private) static class
OperatorMapPair.OuterInnerMapper<T,U,R>
-
Field Summary
Fields Modifier and Type Field Description (package private) Func1<? super T,? extends Observable<? extends U>>
collectionSelector
(package private) Func2<? super T,? super U,? extends R>
resultSelector
-
Constructor Summary
Constructors Constructor Description OperatorMapPair(Func1<? super T,? extends Observable<? extends U>> collectionSelector, Func2<? super T,? super U,? extends R> resultSelector)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Subscriber<? super T>
call(Subscriber<? super Observable<? extends R>> o)
static <T,U>
Func1<T,Observable<U>>convertSelector(Func1<? super T,? extends java.lang.Iterable<? extends U>> selector)
Creates the function that generates aObservable
based on an item emitted by anotherObservable
.
-
-
-
Method Detail
-
convertSelector
public static <T,U> Func1<T,Observable<U>> convertSelector(Func1<? super T,? extends java.lang.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
public Subscriber<? super T> call(Subscriber<? super Observable<? extends R>> o)
-
-