-
- All Implemented Interfaces:
-
com.tds.common.reactor.Observer
public class SerializedSubject<T, R> extends Subject<T, R>
-
-
Constructor Summary
Constructors Constructor Description SerializedSubject(Subject<T, R> actual)
-
Method Summary
Modifier and Type Method Description voidonCompleted()voidonError(Throwable e)voidonNext(T t)booleanhasObservers()Indicates whether the Subject has Observers subscribed to it. -
Methods inherited from class com.tds.common.reactor.subjects.Subject
toSerialized -
Methods inherited from class com.tds.common.reactor.Observable
create, debounce, doOnError, empty, error, filter, flatMap, from, from, just, just, just, just, just, lift, map, merge, observeOn, observeOn, observeOn, onErrorResumeNext, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeOn, timeout, timeout, toList, unsafeCreate, unsafeSubscribe -
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
Method Detail
-
onCompleted
void onCompleted()
-
hasObservers
boolean hasObservers()
-
-
-
-