Top Annotations Classes Enums
[default module]

Package rx.internal.util


Annotation Summary

Modifier and TypeAnnotation and Description
public @interface
SuppressAnimalSniffer

Suppress errors by the AnimalSniffer plugin.

Class Summary

Modifier and TypeClass and Description
public class
ActionNotificationObserver<
the value type
T
>

An Observer that forwards the onXXX method calls to a notification callback by transforming each signal type into Notifications.

public class
ActionObserver<
the value type
T
>

An Observer that forwards the onXXX method calls to callbacks.

public class
ActionSubscriber<
the value type
T
>

A Subscriber that forwards the onXXX method calls to callbacks.

public class
BackpressureDrainManager

Manages the producer-backpressure-consumer interplay by matching up available elements with requested elements and/or terminal events.

public class
BlockingUtils

Utility functions relating to blocking types.

public class
IndexedRingBuffer<E>

Add/Remove without object allocation (after initial construction).

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
ObserverSubscriber<
the value type
T
>

Wraps an Observer and forwards the onXXX method calls to it.

public class
OpenHashSet<
the element type
T
>

A simple open hash set with add, remove and clear capabilities only.

public class
PlatformDependent

Allow platform dependent logic such as checks for Android.

public class
RxRingBuffer

This assumes Spsc or Spmc usage.

public class
public class
ScalarSynchronousObservable<
the value type
T
>

An Observable that emits a single constant scalar value to Subscribers.

public class
public class
SubscriptionList

Subscription that represents a group of Subscriptions that are unsubscribed together.

public class
UtilityFunctions

Utility functions for internal use that we don't want part of the public API.

Enum Summary

Modifier and TypeEnum and Description
public enum
ExceptionsUtils

Utility methods for terminal atomics with Throwables.

public enum
InternalObservableUtils

Holder of named utility classes factored out from Observable to save source space and help with debugging with properly named objects.