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
final 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) final AtomicReference<Subject<? super T,? extends R>>	OperatorMulticast.connectedSubject
(package private) final Queue<Subject<T,T>>	OperatorWindowWithSize.WindowOverlap.queue
(package private) final Func0<? extends Subject<? super T,? extends R>>	OperatorMulticast.subjectFactory
(package private) final 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, 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 Subject

Modifier	Constructor	Description
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)
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.subjects

Modifier and Type	Class	Description
final class	AsyncSubject<T>	Subject that publishes only the last item observed to each Observer once the source Observable has completed.
final class	BehaviorSubject<T>	Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.
final class	PublishSubject<T>	Subject that, once an Observer has subscribed, emits all subsequently observed items to the subscriber.
final 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.
final class	TestSubject<T>	A variety of Subject that is useful for testing purposes.
final 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 final Subject<T,R>	SerializedSubject.actual

Constructors in rx.subjects with parameters of type Subject

Modifier	Constructor	Description
	SerializedSubject(Subject<T,R> actual)