Package rx.internal.util

Package Summary

Package

Description

rx.internal.util.atomic

rx.internal.util.unsafe
Interface Summary

Interface

Description

BackpressureDrainManager.BackpressureQueueCallback

Interface representing the minimal callbacks required to operate the drain part of a backpressure system.
Class Summary

Class

Description

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

LinkedArrayList

A list implementation which combines an ArrayList with a LinkedList to avoid copying values when the capacity needs to be increased.

ObjectPool<T>

PlatformDependent

Allow platform dependent logic such as checks for Android.

RxJavaPluginUtils

RxRingBuffer

This assumes Spsc or Spmc usage.

RxThreadFactory

ScalarSynchronousObservable<T>

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.

SynchronizedSubscription

UtilityFunctions

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