-
- 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 class FlowOnSubscribe<T> implements Observable.OnSubscribe<T>
-
-
Constructor Summary
Constructors Constructor Description FlowOnSubscribe(Observable.OnSubscribe<FlowArbiter.FlowResult<T>> upstream)
-
Method Summary
Modifier and Type Method Description voidcall(Subscriber<out Object> subscriber)-
-
Constructor Detail
-
FlowOnSubscribe
FlowOnSubscribe(Observable.OnSubscribe<FlowArbiter.FlowResult<T>> upstream)
-
-
Method Detail
-
call
void call(Subscriber<out Object> subscriber)
-
-
-
-