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