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 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 NotificationLite

Modifier and Type	Method	Description
static <T> NotificationLite<T>	NotificationLite.instance()	Gets the NotificationLite singleton.

Uses of NotificationLite in rx.internal.util

Fields in rx.internal.util declared as NotificationLite

Modifier and Type	Field	Description
private 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

Modifier and Type	Field	Description
private final NotificationLite<T>	SerializedObserver.nl

Uses of NotificationLite in rx.subjects

Fields in rx.subjects declared as NotificationLite

Modifier and Type	Field	Description
private 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 NotificationLite

Modifier and Type	Method	Description
(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.