Top Description Classes
[default module]

Package rx.subjects


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

Class Summary

Modifier and TypeClass and Description
public class
AsyncSubject<
the type of item expected to be observed by the Subject
T
>

Subject that publishes only the last item observed to each Observer once the source Observable has completed.

public class
BehaviorSubject<
the type of item expected to be observed by the Subject
T
>

Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.

public class
PublishSubject<
the type of items observed and emitted by the Subject
T
>

Subject that, once an Observer has subscribed, emits all subsequently observed items to the subscriber.

public class
ReplaySubject<
the type of items observed and emitted by the Subject
T
>

Subject that buffers all items it observes and replays them to any Observer that subscribes.

public class
SerializedSubject<
the input value type
T
,
the output value type
R
>

Wraps a Subject so that it is safe to call its various on methods from different threads.

public abstract class
Subject<
the input value type
T
,
the output value type
R
>

Represents an object that is both an Observable and an Observer.

pack-priv class
SubjectSubscriptionManager<
the source and return value type
T
>

Represents the typical state and OnSubscribe logic for a Subject implementation.

public class
TestSubject<
the type of item observed by and emitted by the subject
T
>

A variety of Subject that is useful for testing purposes.

public class
UnicastSubject<
the input and output value type
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.