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 source Observable
U - the type of items emitted by the derived Observables
R - the type of items to be emitted by this Operator
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.
  • Field Details

    • collectionSelector

      final Func1<? super T,? extends Observable<? extends U>> collectionSelector
    • resultSelector

      final Func2<? super T,? super U,? extends R> resultSelector
  • Constructor Details

    • OperatorMapPair

      public OperatorMapPair(Func1<? super T,? extends Observable<? extends U>> collectionSelector, Func2<? super T,? super U,? extends R> resultSelector)
  • 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 a Observable based on an item emitted by another Observable.
      Type Parameters:
      T - the input value type
      U - the value type of the generated Observable
      Parameters:
      selector - a function that accepts an item and returns an Iterable of corresponding items
      Returns:
      a function that converts an item emitted by the source Observable into an Observable that emits the items generated by selector operating on that item
    • call

      public Subscriber<? super T> call(Subscriber<? super Observable<? extends R>> o)
      Specified by:
      call in interface Func1<T,U>