AppendOnlyLinkedArrayList<T> |
A linked-array-list implementation that only supports appending and consumption.
|
AtomicThrowable |
Atomic container for Throwables including combining and having a
terminal state via ExceptionHelper.
|
BackpressureHelper |
Utility class to help with backpressure-related operations such as request aggregation.
|
BlockingHelper |
Utility methods for helping common blocking operations.
|
BlockingIgnoringReceiver |
Stores an incoming Throwable (if any) and counts itself down.
|
ConnectConsumer |
Store the Disposable received from the connection.
|
EndConsumerHelper |
Utility class to help report multiple subscriptions with the same
consumer type instead of the internal "Disposable already set!" message
that is practically reserved for internal operators and indicate bugs in them.
|
ExceptionHelper |
Terminal atomics for Throwable containers.
|
ExceptionHelper.Termination |
|
HalfSerializer |
Utility methods to perform half-serialization: a form of serialization
where onNext is guaranteed to be called from a single thread but
onError or onComplete may be called from any threads.
|
LinkedArrayList |
A list implementation which combines an ArrayList with a LinkedList to
avoid copying values when the capacity needs to be increased.
|
MergerBiFunction<T> |
A BiFunction that merges two Lists into a new list.
|
NotificationLite.DisposableNotification |
Wraps a Disposable.
|
NotificationLite.ErrorNotification |
Wraps a Throwable.
|
NotificationLite.SubscriptionNotification |
Wraps a Subscription.
|
OpenHashSet<T> |
A simple open hash set with add, remove and clear capabilities only.
|
Pow2 |
|
QueueDrainHelper |
Utility class to help with the queue-drain serialization idiom.
|
SorterFunction<T> |
|
VolatileSizeArrayList<T> |
Tracks the current underlying array size in a volatile field.
|