ActionNotificationObserver<T> |
An Observer that forwards the onXXX method calls to a notification callback
by transforming each signal type into Notifications.
|
ActionSubscriber<T> |
A Subscriber that forwards the onXXX method calls to callbacks.
|
BackpressureDrainManager |
Manages the producer-backpressure-consumer interplay by
matching up available elements with requested elements and/or
terminal events.
|
BlockingUtils |
Utility functions relating to blocking types.
|
IndexedRingBuffer<E> |
Add/Remove without object allocation (after initial construction).
|
IndexedRingBuffer.ElementSection<E> |
|
IndexedRingBuffer.IndexSection |
|
InternalObservableUtils.CollectorCaller<T,R> |
|
InternalObservableUtils.EqualsWithFunc1 |
|
InternalObservableUtils.ErrorNotImplementedAction |
|
InternalObservableUtils.IsInstanceOfFunc1 |
|
InternalObservableUtils.NotificationErrorExtractor |
|
InternalObservableUtils.ObjectEqualsFunc2 |
|
InternalObservableUtils.PlusOneFunc2 |
|
InternalObservableUtils.PlusOneLongFunc2 |
|
InternalObservableUtils.RepeatNotificationDematerializer |
|
InternalObservableUtils.ReplaySupplierBuffer<T> |
|
InternalObservableUtils.ReplaySupplierBufferTime<T> |
|
InternalObservableUtils.ReplaySupplierNoParams<T> |
|
InternalObservableUtils.ReplaySupplierTime<T> |
|
InternalObservableUtils.RetryNotificationDematerializer |
|
InternalObservableUtils.ReturnsVoidFunc1 |
|
InternalObservableUtils.SelectorAndObserveOn<T,R> |
|
InternalObservableUtils.ToArrayFunc1 |
|
LinkedArrayList |
A list implementation which combines an ArrayList with a LinkedList to
avoid copying values when the capacity needs to be increased.
|
ObjectPool<T> |
|
ObserverSubscriber<T> |
Wraps an Observer and forwards the onXXX method calls to it.
|
OpenHashSet<T> |
A simple open hash set with add, remove and clear capabilities only.
|
PlatformDependent |
Allow platform dependent logic such as checks for Android.
|
RxRingBuffer |
This assumes Spsc or Spmc usage.
|
RxThreadFactory |
|
ScalarSynchronousObservable<T> |
An Observable that emits a single constant scalar value to Subscribers.
|
ScalarSynchronousObservable.JustOnSubscribe<T> |
The OnSubscribe callback for the Observable constructor.
|
ScalarSynchronousObservable.ScalarAsyncOnSubscribe<T> |
The OnSubscribe implementation that creates the ScalarAsyncProducer for each
incoming subscriber.
|
ScalarSynchronousObservable.ScalarAsyncProducer<T> |
Represents a producer which schedules the emission of a scalar value on
the first positive request via the given scheduler callback.
|
ScalarSynchronousObservable.WeakSingleProducer<T> |
This is the weak version of SingleProducer that uses plain fields
to avoid reentrancy and as such is not threadsafe for concurrent
request() calls.
|
ScalarSynchronousSingle<T> |
|
ScalarSynchronousSingle.DirectScheduledEmission<T> |
Optimized observeOn for scalar value observed on the EventLoopsScheduler.
|
ScalarSynchronousSingle.NormalScheduledEmission<T> |
Emits a scalar value on a general scheduler.
|
ScalarSynchronousSingle.ScalarSynchronousSingleAction<T> |
Action that emits a single value when called.
|
SubscriptionList |
Subscription that represents a group of Subscriptions that are unsubscribed together.
|
SynchronizedQueue<T> |
Intended for use when the `sun.misc.Unsafe` implementations can't be used.
|
UtilityFunctions |
Utility functions for internal use that we don't want part of the public API.
|