Uses of Class
rx.subjects.Subject
-
Packages that use Subject Package Description rx.internal.operators Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.rx.subjects Classes extending the Observable base reactive class and implementing the Observer interface at the same time (aka hot Observables). -
-
Uses of Subject in rx.internal.operators
Subclasses of Subject in rx.internal.operators Modifier and Type Class Description class
BufferUntilSubscriber<T>
A solution to the "time gap" problem that occurs withgroupBy
andpivot
.Fields in rx.internal.operators declared as Subject Modifier and Type Field Description (package private) Subject<T,T>
OperatorWindowWithSize.WindowExact. window
(package private) Subject<T,T>
OperatorWindowWithSize.WindowSkip. window
Fields in rx.internal.operators with type parameters of type Subject Modifier and Type Field Description (package private) java.util.concurrent.atomic.AtomicReference<Subject<? super T,? extends R>>
OperatorMulticast. connectedSubject
(package private) java.util.Queue<Subject<T,T>>
OperatorWindowWithSize.WindowOverlap. queue
(package private) Func0<? extends Subject<? super T,? extends R>>
OperatorMulticast. subjectFactory
(package private) java.util.ArrayDeque<Subject<T,T>>
OperatorWindowWithSize.WindowOverlap. windows
Method parameters in rx.internal.operators with type arguments of type Subject Modifier and Type Method Description (package private) boolean
OperatorWindowWithSize.WindowOverlap. checkTerminated(boolean d, boolean empty, Subscriber<? super Subject<T,T>> a, java.util.Queue<Subject<T,T>> q)
(package private) boolean
OperatorWindowWithSize.WindowOverlap. checkTerminated(boolean d, boolean empty, Subscriber<? super Subject<T,T>> a, java.util.Queue<Subject<T,T>> q)
Constructor parameters in rx.internal.operators with type arguments of type Subject Constructor Description OperatorMulticast(java.lang.Object guard, java.util.concurrent.atomic.AtomicReference<Subject<? super T,? extends R>> connectedSubject, java.util.List<Subscriber<? super R>> waitingForConnect, Observable<? extends T> source, Func0<? extends Subject<? super T,? extends R>> subjectFactory)
OperatorMulticast(java.lang.Object guard, java.util.concurrent.atomic.AtomicReference<Subject<? super T,? extends R>> connectedSubject, java.util.List<Subscriber<? super R>> waitingForConnect, Observable<? extends T> source, Func0<? extends Subject<? super T,? extends R>> subjectFactory)
OperatorMulticast(Observable<? extends T> source, Func0<? extends Subject<? super T,? extends R>> subjectFactory)
-
Uses of Subject in rx.subjects
Subclasses of Subject in rx.subjects Modifier and Type Class Description class
AsyncSubject<T>
Subject that publishes only the last item observed to eachObserver
once the sourceObservable
has completed.class
BehaviorSubject<T>
Subject that emits the most recent item it has observed and all subsequent observed items to each subscribedObserver
.class
PublishSubject<T>
Subject that, once anObserver
has subscribed, emits all subsequently observed items to the subscriber.class
ReplaySubject<T>
Subject that buffers all items it observes and replays them to anyObserver
that subscribes.class
SerializedSubject<T,R>
Wraps aSubject
so that it is safe to call its variouson
methods from different threads.class
TestSubject<T>
A variety of Subject that is useful for testing purposes.class
UnicastSubject<T>
A Subject variant which buffers events until a single Subscriber arrives and replays them to it and potentially switches to direct delivery once the Subscriber caught up and requested an unlimited amount.Fields in rx.subjects declared as Subject Modifier and Type Field Description private Subject<T,R>
SerializedSubject. actual
Constructors in rx.subjects with parameters of type Subject Constructor Description SerializedSubject(Subject<T,R> actual)
-