Uses of Class
rx.subjects.SubjectSubscriptionManager.SubjectObserver

Packages that use SubjectSubscriptionManager.SubjectObserver

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

Uses of SubjectSubscriptionManager.SubjectObserver in rx.subjects

Fields in rx.subjects declared as SubjectSubscriptionManager.SubjectObserver

Modifier and Type	Field	Description
(package private) static final SubjectSubscriptionManager.SubjectObserver[]	SubjectSubscriptionManager.State.NO_OBSERVERS
(package private) final SubjectSubscriptionManager.SubjectObserver[]	SubjectSubscriptionManager.State.observers

Fields in rx.subjects with type parameters of type SubjectSubscriptionManager.SubjectObserver

Modifier and Type	Field	Description
(package private) Action1<SubjectSubscriptionManager.SubjectObserver<T>>	SubjectSubscriptionManager.onAdded	Action called after the subscriber has been added to the state.
(package private) Action1<SubjectSubscriptionManager.SubjectObserver<T>>	SubjectSubscriptionManager.onStart	Action called when a new subscriber subscribes but before it is added to the state.
(package private) Action1<SubjectSubscriptionManager.SubjectObserver<T>>	SubjectSubscriptionManager.onTerminated	Action called when the subscriber wants to subscribe to a terminal state.

Methods in rx.subjects that return SubjectSubscriptionManager.SubjectObserver

Modifier and Type	Method	Description
(package private) SubjectSubscriptionManager.SubjectObserver<T>[]	SubjectSubscriptionManager.next(Object n)	Set a new latest NotificationLite value and return the active observers.
(package private) SubjectSubscriptionManager.SubjectObserver<T>[]	SubjectSubscriptionManager.observers()
(package private) SubjectSubscriptionManager.SubjectObserver<T>[]	SubjectSubscriptionManager.terminate(Object n)	Atomically set the terminal NotificationLite value (which could be any of the 3), clear the active observers and return the last active observers.

Methods in rx.subjects with parameters of type SubjectSubscriptionManager.SubjectObserver

Modifier and Type	Method	Description
(package private) boolean	SubjectSubscriptionManager.add(SubjectSubscriptionManager.SubjectObserver<T> o)	Try to atomically add a SubjectObserver to the active state.
SubjectSubscriptionManager.State	SubjectSubscriptionManager.State.add(SubjectSubscriptionManager.SubjectObserver o)
(package private) void	SubjectSubscriptionManager.addUnsubscriber(Subscriber<? super T> child, SubjectSubscriptionManager.SubjectObserver<T> bo)	Registers the unsubscribe action for the given subscriber.
(package private) void	SubjectSubscriptionManager.remove(SubjectSubscriptionManager.SubjectObserver<T> o)	Atomically remove the specified SubjectObserver from the active observers.
SubjectSubscriptionManager.State	SubjectSubscriptionManager.State.remove(SubjectSubscriptionManager.SubjectObserver o)

Constructors in rx.subjects with parameters of type SubjectSubscriptionManager.SubjectObserver

Modifier	Constructor	Description
	State(boolean terminated, SubjectSubscriptionManager.SubjectObserver[] observers)