Package rx.subjects

Classes extending the Observable base reactive class and implementing the Observer interface at the same time (aka hot Observables).

See: Description

Class Summary

Class	Description
AsyncSubject<T>	Subject that publishes only the last item observed to each Observer once the source Observable has completed.
BehaviorSubject<T>	Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.
PublishSubject<T>	Subject that, once an Observer has subscribed, emits all subsequently observed items to the subscriber.
ReplaySubject<T>	Subject that buffers all items it observes and replays them to any Observer that subscribes.
SerializedSubject<T,R>	Wraps a Subject so that it is safe to call its various on methods from different threads.
Subject<T,R>	Represents an object that is both an Observable and an Observer.
TestSubject<T>	A variety of Subject that is useful for testing purposes.
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.

Package rx.subjects Description

Classes extending the Observable base reactive class and implementing the Observer interface at the same time (aka hot Observables).