Constructor Detail

• OperatorMapPair

  public OperatorMapPair(Func1<? super T,? extends Observable<? extends U>> collectionSelector,
                         Func2<? super T,? super U,? extends R> resultSelector)

Method Detail

• 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.

  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)