Package rx.subjects

Class Summary

Class

Description

AsyncSubject<T>

Subject that publishes only the last item observed to each Observer that has subscribed, when the source Observable completes.

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.