Package | Description |
---|---|
rx.internal.schedulers | |
rx.internal.util | |
rx.internal.util.unsafe |
Class and Description |
---|
SubscriptionList
Subscription that represents a group of Subscriptions that are unsubscribed together.
|
Class and Description |
---|
BackpressureDrainManager.BackpressureQueueCallback
Interface representing the minimal callbacks required
to operate the drain part of a backpressure system.
|
ExceptionsUtils
Utility methods for terminal atomics with Throwables.
|
IndexedRingBuffer
Add/Remove without object allocation (after initial construction).
|
InternalObservableUtils
Holder of named utility classes factored out from Observable to save
source space and help with debugging with properly named objects.
|
RxRingBuffer
This assumes Spsc or Spmc usage.
|
ScalarSynchronousObservable
An Observable that emits a single constant scalar value to Subscribers.
|
ScalarSynchronousSingle |
Class and Description |
---|
SuppressAnimalSniffer
Suppress errors by the AnimalSniffer plugin.
|
Copyright © 2018. All rights reserved.