Interface | Description |
---|---|
BackpressureDrainManager.BackpressureQueueCallback |
Interface representing the minimal callbacks required
to operate the drain part of a backpressure system.
|
Class | Description |
---|---|
ActionNotificationObserver<T> |
An Observer that forwards the onXXX method calls to a notification callback
by transforming each signal type into Notifications.
|
ActionObserver<T> |
An Observer that forwards the onXXX method calls to callbacks.
|
ActionSubscriber<T> |
A Subscriber that forwards the onXXX method calls to callbacks.
|
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.
|
ObserverSubscriber<T> |
Wraps an Observer and forwards the onXXX method calls to it.
|
OpenHashSet<T> |
A simple open hash set with add, remove and clear capabilities only.
|
PlatformDependent |
Allow platform dependent logic such as checks for Android.
|
RxRingBuffer |
This assumes Spsc or Spmc usage.
|
RxThreadFactory | |
ScalarSynchronousObservable<T> |
An Observable that emits a single constant scalar value to Subscribers.
|
ScalarSynchronousSingle<T> | |
SubscriptionList |
Subscription that represents a group of Subscriptions that are unsubscribed together.
|
UtilityFunctions |
Utility functions for internal use that we don't want part of the public API.
|
Enum | Description |
---|---|
ExceptionsUtils |
Utility methods for terminal atomics with Throwables.
|
InternalObservableUtils |
Holder of named utility classes factored out from Observable to save
source space and help with debugging with properly named objects.
|
Annotation Type | Description |
---|---|
SuppressAnimalSniffer |
Suppress errors by the AnimalSniffer plugin.
|
Copyright © 2018. All rights reserved.