Package rx.internal.operators

Class OnSubscribeMap<T,R>

java.lang.Object
rx.internal.operators.OnSubscribeMap<T,R>
Type Parameters:
T - the input value type
R - the return value type
All Implemented Interfaces:
Action, Action1<Subscriber<? super R>>, Function, Observable.OnSubscribe<R>
public final class OnSubscribeMap<T,R> extends Object implements Observable.OnSubscribe<R>
Applies a function of your choosing to every item emitted by an Observable, and emits the results of this transformation as a new Observable.

  • Field Details

    • source

      final Observable<T> source

    • transformer

      final Func1<? super T,? extends R> transformer

  • Constructor Details

    • OnSubscribeMap

      public OnSubscribeMap(Observable<T> source, Func1<? super T,? extends R> transformer)

  • Method Details