Top Interfaces Annotations Classes Enums

[default module]

Package io.reactivex.internal.util

Interface Summary

Modifier and Type	Interface and Description
public interface	ObservableQueueDrain<T, U>
public interface	QueueDrain<T, U>

Annotation Summary

Modifier and Type	Annotation and Description
public @interface	SuppressAnimalSniffer Suppress errors by the AnimalSniffer plugin.

Class Summary

Modifier and Type	Class and Description
public class	AppendOnlyLinkedArrayList< the value type T> A linked-array-list implementation that only supports appending and consumption.
public class	AtomicThrowable Atomic container for Throwables including combining and having a terminal state via ExceptionHelper.
public class	BackpressureHelper Utility class to help with backpressure-related operations such as request aggregation.
public class	BlockingHelper Utility methods for helping common blocking operations.
public class	BlockingIgnoringReceiver Stores an incoming Throwable (if any) and counts itself down.
public class	ConnectConsumer Store the Disposable received from the connection.
public class	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.
public class	ExceptionHelper Terminal atomics for Throwable containers.
public class	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.
public class	LinkedArrayList A list implementation which combines an ArrayList with a LinkedList to avoid copying values when the capacity needs to be increased.
public class	MergerBiFunction< the value type T> A BiFunction that merges two Lists into a new list.
public class	OpenHashSet< the element type T> A simple open hash set with add, remove and clear capabilities only.
public class	Pow2
public class	QueueDrainHelper Utility class to help with the queue-drain serialization idiom.
public class	SorterFunction<T>
public class	VolatileSizeArrayList< the element type T> Tracks the current underlying array size in a volatile field.

Enum Summary

Modifier and Type	Enum and Description
public enum	ArrayListSupplier
public enum	EmptyComponent Singleton implementing many interfaces as empty.
public enum	ErrorMode Indicates when an error from the main source should be reported.
public enum	HashMapSupplier
public enum	ListAddBiConsumer
public enum	NotificationLite Lightweight notification handling utility class.