Uses of Class
rx.subjects.Subject
Packages that use Subject
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
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.operatorsModifier and TypeClassDescriptionfinal class
A solution to the "time gap" problem that occurs withgroupBy
andpivot
.Fields in rx.internal.operators declared as SubjectModifier and TypeFieldDescriptionOperatorWindowWithSize.WindowExact.window
OperatorWindowWithSize.WindowSkip.window
Fields in rx.internal.operators with type parameters of type SubjectModifier and TypeFieldDescription(package private) final AtomicReference
<Subject<? super T, ? extends R>> OperatorMulticast.connectedSubject
OperatorWindowWithSize.WindowOverlap.queue
OperatorMulticast.subjectFactory
(package private) final ArrayDeque
<Subject<T, T>> OperatorWindowWithSize.WindowOverlap.windows
Method parameters in rx.internal.operators with type arguments of type SubjectModifier and TypeMethodDescription(package private) boolean
OperatorWindowWithSize.WindowOverlap.checkTerminated
(boolean d, boolean empty, Subscriber<? super Subject<T, T>> a, Queue<Subject<T, T>> q) (package private) boolean
OperatorWindowWithSize.WindowOverlap.checkTerminated
(boolean d, boolean empty, Subscriber<? super Subject<T, T>> a, Queue<Subject<T, T>> q) Constructor parameters in rx.internal.operators with type arguments of type SubjectModifierConstructorDescriptionprivate
OperatorMulticast
(Object guard, AtomicReference<Subject<? super T, ? extends R>> connectedSubject, List<Subscriber<? super R>> waitingForConnect, Observable<? extends T> source, Func0<? extends Subject<? super T, ? extends R>> subjectFactory) private
OperatorMulticast
(Object guard, AtomicReference<Subject<? super T, ? extends R>> connectedSubject, 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.subjectsModifier and TypeClassDescriptionfinal class
AsyncSubject<T>
Subject that publishes only the last item observed to eachObserver
once the sourceObservable
has completed.final class
Subject that emits the most recent item it has observed and all subsequent observed items to each subscribedObserver
.final class
Subject that, once anObserver
has subscribed, emits all subsequently observed items to the subscriber.final class
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.final class
TestSubject<T>
A variety of Subject that is useful for testing purposes.final class
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 SubjectConstructors in rx.subjects with parameters of type Subject