-
- All Implemented Interfaces:
-
com.tds.common.reactor.Observer
public abstract class Subject<T, R> extends Observable<R> implements Observer<T>
Represents an object that is both an Observable and an Observer.
-
-
Constructor Summary
Constructors Constructor Description Subject(Observable.OnSubscribe<R> onSubscribe)
-
Method Summary
Modifier and Type Method Description abstract boolean
hasObservers()
Indicates whether the Subject has Observers subscribed to it. final SerializedSubject<T, R>
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 com.tds.common.reactor.Observer
onCompleted, onError, onNext
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
Constructor Detail
-
Subject
Subject(Observable.OnSubscribe<R> onSubscribe)
-
-
Method Detail
-
hasObservers
abstract boolean hasObservers()
-
toSerialized
final SerializedSubject<T, R> toSerialized()
-
-
-
-