-
- 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 voidcall(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)
-
-
-
-