Serialized Form
-
Package rx.exceptions
-
Exception Class rx.exceptions.AssemblyStackTraceException
class AssemblyStackTraceException extends RuntimeException implements Serializable- serialVersionUID:
- 2038859767182585852L
-
Exception Class rx.exceptions.CompositeException
class CompositeException extends RuntimeException implements Serializable- serialVersionUID:
- 3026362227162912146L
-
Exception Class rx.exceptions.MissingBackpressureException
class MissingBackpressureException extends Exception implements Serializable- serialVersionUID:
- 7250870679677032194L
-
Exception Class rx.exceptions.OnCompletedFailedException
class OnCompletedFailedException extends RuntimeException implements Serializable- serialVersionUID:
- 8622579378868820554L
-
Exception Class rx.exceptions.OnErrorFailedException
class OnErrorFailedException extends RuntimeException implements Serializable- serialVersionUID:
- -419289748403337611L
-
Exception Class rx.exceptions.OnErrorNotImplementedException
class OnErrorNotImplementedException extends RuntimeException implements Serializable- serialVersionUID:
- -6298857009889503852L
-
Exception Class rx.exceptions.OnErrorThrowable
class OnErrorThrowable extends RuntimeException implements Serializable- serialVersionUID:
- -569558213262703934L
-
Serialized Fields
-
hasValue
boolean hasValue
-
value
Object value
-
-
Exception Class rx.exceptions.OnErrorThrowable.OnNextValue
class OnNextValue extends RuntimeException implements Serializable- serialVersionUID:
- -3454462756050397899L
-
Serialized Fields
-
value
Object value
-
-
Exception Class rx.exceptions.UnsubscribeFailedException
class UnsubscribeFailedException extends RuntimeException implements Serializable- serialVersionUID:
- 4594672310593167598L
-
-
Package rx.internal.operators
-
Class rx.internal.operators.OnSubscribePublishMulticast
class OnSubscribePublishMulticast extends AtomicInteger implements Serializable- serialVersionUID:
- -3741892510772238743L
-
Serialized Fields
-
delayError
boolean delayError
Delays the error delivery to happen only after all values have been consumed. -
done
boolean done
Indicates the upstream has completed. -
error
Throwable error
Holds onto the upstream's exception if done is true and this field is non-null.This field must be read after done or if subscribers == TERMINATED to establish a proper happens-before.
-
parent
OnSubscribePublishMulticast.ParentSubscriber<T> parent
The subscriber that can be 'connected' to the upstream source. -
prefetch
int prefetch
The number of items to prefetch from the upstreams source. -
producer
Producer producer
Holds the upstream producer if any, set through the parent subscriber. -
queue
Queue<T> queue
The prefetch queue holding onto a fixed amount of items until all all child subscribers have requested something. -
subscribers
OnSubscribePublishMulticast.PublishProducer<T>[] subscribers
A copy-on-write array of currently subscribed child subscribers' wrapper structure.
-
-
-
Package rx.internal.producers
-
Class rx.internal.producers.QueuedProducer
class QueuedProducer extends AtomicLong implements Serializable- serialVersionUID:
- 7277121710709137047L
-
Serialized Fields
-
child
Subscriber<? super T> child
-
done
boolean done
-
error
Throwable error
-
queue
Queue<Object> queue
-
wip
AtomicInteger wip
-
-
Class rx.internal.producers.QueuedValueProducer
class QueuedValueProducer extends AtomicLong implements Serializable- serialVersionUID:
- 7277121710709137047L
-
Serialized Fields
-
child
Subscriber<? super T> child
-
queue
Queue<Object> queue
-
wip
AtomicInteger wip
-
-
Class rx.internal.producers.SingleDelayedProducer
class SingleDelayedProducer extends AtomicInteger implements Serializable- serialVersionUID:
- -2873467947112093874L
-
Serialized Fields
-
child
Subscriber<? super T> child
The child to emit the value and completion once possible. -
value
T value
The value to emit.
-
-
Class rx.internal.producers.SingleProducer
class SingleProducer extends AtomicBoolean implements Serializable- serialVersionUID:
- -3353584923995471404L
-
Serialized Fields
-
child
Subscriber<? super T> child
The child subscriber. -
value
T value
The value to be emitted.
-
-
-
Package rx.internal.schedulers
-
Class rx.internal.schedulers.ScheduledAction
- serialVersionUID:
- -3962399486978279857L
-
Serialized Fields
-
action
Action0 action
-
cancel
SubscriptionList cancel
-
-
-
Package rx.internal.util
-
Class rx.internal.util.BackpressureDrainManager
class BackpressureDrainManager extends AtomicLong implements Serializable- serialVersionUID:
- 2826241102729529449L
-
Serialized Fields
-
actual
BackpressureDrainManager.BackpressureQueueCallback actual
The callbacks to manage the drain. -
emitting
boolean emitting
Indicates if one is in emitting phase, guarded by this. -
exception
Throwable exception
Indicates an error state, barrier is provided via terminated. -
terminated
boolean terminated
Indicates a terminal state.
-
-
Class rx.internal.util.RxThreadFactory
class RxThreadFactory extends AtomicLong implements Serializable- serialVersionUID:
- -8841098858898482335L
-
Serialized Fields
-
prefix
String prefix
-
-
-
Package rx.internal.util.atomic
-
Class rx.internal.util.atomic.LinkedQueueNode
- serialVersionUID:
- 2404266111789071508L
-
Serialized Fields
-
value
E value
-
-
Class rx.internal.util.atomic.SpscExactAtomicArrayQueue
- serialVersionUID:
- 6210984603741293445L
-
Serialized Fields
-
capacitySkip
int capacitySkip
-
consumerIndex
AtomicLong consumerIndex
-
mask
int mask
-
producerIndex
AtomicLong producerIndex
-
-