-
- 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 void
onNext(T t)
void
onError(Throwable e)
void
onCompleted()
-