Uses of Class
rx.internal.operators.NotificationLite
Packages that use NotificationLite
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
Default wrappers and implementations for the base reactive consumer classes and interfaces;
utility classes for creating them from callbacks.
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 NotificationLiteModifier and TypeFieldDescriptionprivate static final NotificationLite
NotificationLite.INSTANCE
(package private) final NotificationLite
<T> BlockingOperatorMostRecent.MostRecentObserver.nl
(package private) final NotificationLite
<T> BufferUntilSubscriber.State.nl
(package private) final NotificationLite
<T> CachedObservable.CacheState.nl
(package private) final NotificationLite
<T> OnSubscribeCombineLatest.CombinerSubscriber.nl
(package private) final NotificationLite
<T> OnSubscribeFlattenIterable.FlattenIterableSubscriber.nl
(package private) final NotificationLite
<T> OnSubscribeFromAsync.BufferAsyncEmitter.nl
(package private) final NotificationLite
<T> OnSubscribeFromAsync.LatestAsyncEmitter.nl
(package private) final NotificationLite
<T> OperatorEagerConcatMap.EagerInnerSubscriber.nl
(package private) final NotificationLite
<T> OperatorMerge.MergeSubscriber.nl
(package private) final NotificationLite
<T> OperatorPublish.PublishSubscriber.nl
The notification-lite factory.(package private) final NotificationLite
<T> OperatorReplay.BoundedReplayBuffer.nl
(package private) final NotificationLite
<T> OperatorReplay.ReplaySubscriber.nl
The notification-lite factory.(package private) final NotificationLite
<T> OperatorReplay.UnboundedReplayBuffer.nl
(package private) final NotificationLite
<T> OperatorSwitch.SwitchSubscriber.nl
(package private) final NotificationLite
<T> OperatorTakeLast.TakeLastSubscriber.nl
(package private) final NotificationLite
<T> OperatorTakeLastTimed.TakeLastTimedSubscriber.nl
(package private) static final NotificationLite
<Object> OperatorWindowWithObservable.NL
For error and completion indication.(package private) static final NotificationLite
<Object> OperatorWindowWithObservableFactory.NL
For error and completion indication.(package private) static final NotificationLite
<Object> OperatorWindowWithTime.NL
For error and completion indication.(package private) final NotificationLite
<T> OperatorObserveOn.ObserveOnSubscriber.on
private final NotificationLite
<T> OperatorOnBackpressureBuffer.BufferSubscriber.on
Methods in rx.internal.operators that return NotificationLiteModifier and TypeMethodDescriptionstatic <T> NotificationLite
<T> NotificationLite.instance()
Gets theNotificationLite
singleton. -
Uses of NotificationLite in rx.internal.util
Fields in rx.internal.util declared as NotificationLiteModifier and TypeFieldDescriptionprivate static final NotificationLite
<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 -
Uses of NotificationLite in rx.subjects
Fields in rx.subjects declared as NotificationLiteModifier and TypeFieldDescriptionprivate final NotificationLite
<T> AsyncSubject.nl
private final NotificationLite
<T> BehaviorSubject.nl
private final NotificationLite
<T> PublishSubject.nl
final NotificationLite
<T> SubjectSubscriptionManager.nl
The notification lite.(package private) final NotificationLite
<T> UnicastSubject.State.nl
JCTools queues don't accept nulls.Methods in rx.subjects with parameters of type NotificationLiteModifier and TypeMethodDescription(package private) void
SubjectSubscriptionManager.SubjectObserver.accept
(Object n, NotificationLite<T> nl) Dispatches a NotificationLite value to the actual Observer.(package private) void
SubjectSubscriptionManager.SubjectObserver.emitFirst
(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
(List<Object> localQueue, Object current, NotificationLite<T> nl) Emits the contents of the queue as long as there are values.(package private) void
SubjectSubscriptionManager.SubjectObserver.emitNext
(Object n, NotificationLite<T> nl) Emits the given NotificationLite value and prevents the emitFirst to run if not already run.