Uses of Class
rx.subjects.SubjectSubscriptionManager.SubjectObserver
Packages that use SubjectSubscriptionManager.SubjectObserver
Package
Description
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.SubjectObserverModifier and TypeFieldDescription(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.SubjectObserverModifier and TypeFieldDescription(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.SubjectObserverModifier and TypeMethodDescription(package private) SubjectSubscriptionManager.SubjectObserver<T>[]
Set a new latest NotificationLite value and return the active observers.(package private) SubjectSubscriptionManager.SubjectObserver<T>[]
SubjectSubscriptionManager.observers()
(package private) SubjectSubscriptionManager.SubjectObserver<T>[]
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.SubjectObserverModifier and TypeMethodDescription(package private) boolean
SubjectSubscriptionManager.add
(SubjectSubscriptionManager.SubjectObserver<T> o) Try to atomically add a SubjectObserver to the active 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.remove
(SubjectSubscriptionManager.SubjectObserver o) Constructors in rx.subjects with parameters of type SubjectSubscriptionManager.SubjectObserverModifierConstructorDescriptionState
(boolean terminated, SubjectSubscriptionManager.SubjectObserver[] observers)