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