Package 

Class OnSubscribeMap

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

    • Method Summary

      Modifier and Type Method Description
      void call(Subscriber<out Object> o)
      • Methods inherited from class com.tds.common.reactor.functions.Action1

        call
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait