Package io.reactivex.rxjava3.internal.util
package io.reactivex.rxjava3.internal.util
-
ClassDescriptionA linked-array-list implementation that only supports appending and consumption.Predicate interface suppressing the exception.Atomic container for Throwables including combining and having a terminal state via ExceptionHelper.Utility class to help with backpressure-related operations such as request aggregation.Utility methods for helping common blocking operations.Stores an incoming Throwable (if any) and counts itself down.Store the Disposable received from the connection.Singleton implementing many interfaces as empty.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.Indicates when an error from the main source should be reported.Terminal atomics for Throwable containers.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.A list implementation which combines an ArrayList with a LinkedList to avoid copying values when the capacity needs to be increased.A BiFunction that merges two Lists into a new list.Lightweight notification handling utility class.Wraps a Disposable.Wraps a Throwable.Wraps a Subscription.ObservableQueueDrain<T,
U> OpenHashSet<T>A simple open hash set with add, remove and clear capabilities only.QueueDrain<T,U> Utility class to help with the queue-drain serialization idiom.Suppress errors by the AnimalSniffer plugin.Tracks the current underlying array size in a volatile field.