-
- All Implemented Interfaces:
-
com.tds.common.reactor.Observable.OnSubscribe
,com.tds.common.reactor.functions.Action
,com.tds.common.reactor.functions.Action1
,com.tds.common.reactor.functions.Function
public final class OnSubscribeMap<T, R> implements Observable.OnSubscribe<R>
Applies a function of your choosing to every item emitted by an
{@code Observable}
, and emits the results of this transformation as a new{@code Observable}
.
-
-
Constructor Summary
Constructors Constructor Description OnSubscribeMap(Observable<T> source, Func1<out Object, out R> transformer)
-
Method Summary
Modifier and Type Method Description void
call(Subscriber<out Object> o)
-
-
Constructor Detail
-
OnSubscribeMap
OnSubscribeMap(Observable<T> source, Func1<out Object, out R> transformer)
-
-
Method Detail
-
call
void call(Subscriber<out Object> o)
-
-
-
-