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