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 with groupBy and pivot.

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 each Observer once the source Observable has completed.
class	BehaviorSubject<T>	Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.
class	PublishSubject<T>	Subject that, once an Observer has subscribed, emits all subsequently observed items to the subscriber.
class	ReplaySubject<T>	Subject that buffers all items it observes and replays them to any Observer that subscribes.
class	SerializedSubject<T,R>	Wraps a Subject so that it is safe to call its various on 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)