-
- All Implemented Interfaces:
-
com.tds.common.reactor.Observer,com.tds.common.reactor.Subscription
public class ObserverSubscriber<T> extends Subscriber<T>
-
-
Constructor Summary
Constructors Constructor Description ObserverSubscriber(Observer<out Object> observer)
-
Method Summary
Modifier and Type Method Description voidonNext(T t)voidonError(Throwable e)voidonCompleted()
-