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 SubjectSubscriptionManager.SubjectObserver[]
SubjectSubscriptionManager.State. NO_OBSERVERS
(package private) 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(java.lang.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(java.lang.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 Constructor Description State(boolean terminated, SubjectSubscriptionManager.SubjectObserver[] observers)
-