Package rx.internal.util

Package Summary

Package

Description

rx.internal.util.unsafe
Class Summary

Class

Description

IndexedRingBuffer<E>

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

ObjectPool<T>

PaddedAtomicInteger

A padded atomic integer to fill in 4 cache lines to avoid any false sharing or adjacent prefetch.

PlatformDependent

Allow platform dependent logic such as checks for Android.

RxRingBuffer

This assumes Spsc or Spmc usage.

RxThreadFactory

ScalarSynchronousObservable<T>

SubscriptionIndexedRingBuffer<T extends Subscription >

Similar to CompositeSubscription but giving extra access to internals so we can reuse a datastructure.

SubscriptionList

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

SubscriptionRandomList<T extends Subscription >

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.