Uses of Package
rx.subjects

Packages that use rx.subjects

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).

Classes in rx.subjects used by rx.internal.operators

Class	Description
Subject	Represents an object that is both an Observable and an Observer.

Classes in rx.subjects used by rx.subjects

Class	Description
AsyncSubject	Subject that publishes only the last item observed to each Observer once the source Observable has completed.
BehaviorSubject	Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.
PublishSubject	Subject that, once an Observer has subscribed, emits all subsequently observed items to the subscriber.
ReplaySubject	Subject that buffers all items it observes and replays them to any Observer that subscribes.
ReplaySubject.ReplayBuffer	The base interface for buffering signals to be replayed to individual Subscribers.
ReplaySubject.ReplayProducer	A producer and subscription implementation that tracks the current replay position of a particular subscriber.
ReplaySubject.ReplaySizeAndTimeBoundBuffer.TimedNode
ReplaySubject.ReplaySizeBoundBuffer.Node
ReplaySubject.ReplayState	Holds onto the array of Subscriber-wrapping ReplayProducers and the buffer that holds values to be replayed; it manages subscription and signal dispatching.
SerializedSubject	Wraps a Subject so that it is safe to call its various on methods from different threads.
Subject	Represents an object that is both an Observable and an Observer.
SubjectSubscriptionManager	Represents the typical state and OnSubscribe logic for a Subject implementation.
SubjectSubscriptionManager.State	State-machine representing the termination state and active SubjectObservers.
SubjectSubscriptionManager.SubjectObserver	Observer wrapping the actual Subscriber and providing various emission facilities.
TestSubject	A variety of Subject that is useful for testing purposes.
UnicastSubject	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.
UnicastSubject.State	The single-consumption replaying state.