Uses of Class
rx.internal.operators.NotificationLite
-
Packages that use NotificationLite Package Description rx.internal.operators Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.rx.internal.util rx.observers Default wrappers and implementations for the base reactive consumer classes and interfaces; utility classes for creating them from callbacks.rx.subjects Classes extending the Observable base reactive class and implementing the Observer interface at the same time (aka hot Observables). -
-
Uses of NotificationLite in rx.internal.operators
Fields in rx.internal.operators declared as NotificationLite Modifier and Type Field Description private static NotificationLite
NotificationLite. INSTANCE
(package private) NotificationLite<T>
BlockingOperatorMostRecent.MostRecentObserver. nl
(package private) NotificationLite<T>
BufferUntilSubscriber.State. nl
(package private) NotificationLite<T>
CachedObservable.CacheState. nl
(package private) NotificationLite<T>
OnSubscribeCombineLatest.CombinerSubscriber. nl
(package private) NotificationLite<T>
OnSubscribeFlattenIterable.FlattenIterableSubscriber. nl
(package private) NotificationLite<T>
OnSubscribeFromAsync.BufferAsyncEmitter. nl
(package private) NotificationLite<T>
OnSubscribeFromAsync.LatestAsyncEmitter. nl
(package private) NotificationLite<T>
OperatorEagerConcatMap.EagerInnerSubscriber. nl
(package private) NotificationLite<T>
OperatorMerge.MergeSubscriber. nl
(package private) NotificationLite<T>
OperatorPublish.PublishSubscriber. nl
The notification-lite factory.(package private) NotificationLite<T>
OperatorReplay.BoundedReplayBuffer. nl
(package private) NotificationLite<T>
OperatorReplay.ReplaySubscriber. nl
The notification-lite factory.(package private) NotificationLite<T>
OperatorReplay.UnboundedReplayBuffer. nl
(package private) NotificationLite<T>
OperatorSwitch.SwitchSubscriber. nl
(package private) NotificationLite<T>
OperatorTakeLast.TakeLastSubscriber. nl
(package private) NotificationLite<T>
OperatorTakeLastTimed.TakeLastTimedSubscriber. nl
(package private) static NotificationLite<java.lang.Object>
OperatorWindowWithObservable. NL
For error and completion indication.(package private) static NotificationLite<java.lang.Object>
OperatorWindowWithObservableFactory. NL
For error and completion indication.(package private) static NotificationLite<java.lang.Object>
OperatorWindowWithTime. NL
For error and completion indication.(package private) NotificationLite<T>
OperatorObserveOn.ObserveOnSubscriber. on
private NotificationLite<T>
OperatorOnBackpressureBuffer.BufferSubscriber. on
Methods in rx.internal.operators that return NotificationLite Modifier and Type Method Description static <T> NotificationLite<T>
NotificationLite. instance()
Gets theNotificationLite
singleton. -
Uses of NotificationLite in rx.internal.util
Fields in rx.internal.util declared as NotificationLite Modifier and Type Field Description private static NotificationLite<java.lang.Object>
RxRingBuffer. ON
Queue implementation testing that led to current choices of data structures: With synchronized LinkedList -
Uses of NotificationLite in rx.observers
Fields in rx.observers declared as NotificationLite Modifier and Type Field Description private NotificationLite<T>
SerializedObserver. nl
-
Uses of NotificationLite in rx.subjects
Fields in rx.subjects declared as NotificationLite Modifier and Type Field Description private NotificationLite<T>
AsyncSubject. nl
private NotificationLite<T>
BehaviorSubject. nl
private NotificationLite<T>
PublishSubject. nl
NotificationLite<T>
SubjectSubscriptionManager. nl
The notification lite.(package private) NotificationLite<T>
UnicastSubject.State. nl
JCTools queues don't accept nulls.Methods in rx.subjects with parameters of type NotificationLite Modifier and Type Method Description (package private) void
SubjectSubscriptionManager.SubjectObserver. accept(java.lang.Object n, NotificationLite<T> nl)
Dispatches a NotificationLite value to the actual Observer.(package private) void
SubjectSubscriptionManager.SubjectObserver. emitFirst(java.lang.Object n, NotificationLite<T> nl)
Tries to emit a NotificationLite value as the first value and drains the queue as long as possible.(package private) void
SubjectSubscriptionManager.SubjectObserver. emitLoop(java.util.List<java.lang.Object> localQueue, java.lang.Object current, NotificationLite<T> nl)
Emits the contents of the queue as long as there are values.(package private) void
SubjectSubscriptionManager.SubjectObserver. emitNext(java.lang.Object n, NotificationLite<T> nl)
Emits the given NotificationLite value and prevents the emitFirst to run if not already run.
-