Package rx.internal.operators
Class OnSubscribeMap<T,R>
java.lang.Object
rx.internal.operators.OnSubscribeMap<T,R>
- Type Parameters:
T
- the input value typeR
- the return value type
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super R>>
,Function
,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
.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionOnSubscribeMap
(Observable<T> source, Func1<? super T, ? extends R> transformer) -
Method Summary