Serialized Form
-
Package rx.exceptions
-
Class rx.exceptions.AssemblyStackTraceException extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- 2038859767182585852L
-
Class rx.exceptions.CompositeException extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- 3026362227162912146L
-
Serialized Fields
-
cause
java.lang.Throwable cause
-
exceptions
java.util.List<java.lang.Throwable> exceptions
-
message
java.lang.String message
-
-
Class rx.exceptions.MissingBackpressureException extends java.lang.Exception implements Serializable
- serialVersionUID:
- 7250870679677032194L
-
Class rx.exceptions.OnCompletedFailedException extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- 8622579378868820554L
-
Class rx.exceptions.OnErrorFailedException extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- -419289748403337611L
-
Class rx.exceptions.OnErrorNotImplementedException extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- -6298857009889503852L
-
Class rx.exceptions.OnErrorThrowable extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- -569558213262703934L
-
Serialized Fields
-
hasValue
boolean hasValue
-
value
java.lang.Object value
-
-
Class rx.exceptions.OnErrorThrowable.OnNextValue extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- -3454462756050397899L
-
Serialized Fields
-
value
java.lang.Object value
-
-
Class rx.exceptions.UnsubscribeFailedException extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- 4594672310593167598L
-
-
Package rx.internal.operators
-
Class rx.internal.operators.OnSubscribePublishMulticast extends java.util.concurrent.atomic.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
java.lang.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
java.util.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 extends java.util.concurrent.atomic.AtomicLong implements Serializable
- serialVersionUID:
- 7277121710709137047L
-
Serialized Fields
-
child
Subscriber<? super T> child
-
done
boolean done
-
error
java.lang.Throwable error
-
queue
java.util.Queue<java.lang.Object> queue
-
wip
java.util.concurrent.atomic.AtomicInteger wip
-
-
Class rx.internal.producers.QueuedValueProducer extends java.util.concurrent.atomic.AtomicLong implements Serializable
- serialVersionUID:
- 7277121710709137047L
-
Serialized Fields
-
child
Subscriber<? super T> child
-
queue
java.util.Queue<java.lang.Object> queue
-
wip
java.util.concurrent.atomic.AtomicInteger wip
-
-
Class rx.internal.producers.SingleDelayedProducer extends java.util.concurrent.atomic.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 extends java.util.concurrent.atomic.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 extends java.util.concurrent.atomic.AtomicReference<java.lang.Thread> implements Serializable
- serialVersionUID:
- -3962399486978279857L
-
Serialized Fields
-
action
Action0 action
-
cancel
SubscriptionList cancel
-
-
-
Package rx.internal.util
-
Class rx.internal.util.BackpressureDrainManager extends java.util.concurrent.atomic.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
java.lang.Throwable exception
Indicates an error state, barrier is provided via terminated. -
terminated
boolean terminated
Indicates a terminal state.
-
-
Class rx.internal.util.RxThreadFactory extends java.util.concurrent.atomic.AtomicLong implements Serializable
- serialVersionUID:
- -8841098858898482335L
-
Serialized Fields
-
prefix
java.lang.String prefix
-
-
-
Package rx.internal.util.atomic
-
Class rx.internal.util.atomic.LinkedQueueNode extends java.util.concurrent.atomic.AtomicReference<LinkedQueueNode<E>> implements Serializable
- serialVersionUID:
- 2404266111789071508L
-
Serialized Fields
-
value
E value
-
-
Class rx.internal.util.atomic.SpscExactAtomicArrayQueue extends java.util.concurrent.atomic.AtomicReferenceArray<T> implements Serializable
- serialVersionUID:
- 6210984603741293445L
-
Serialized Fields
-
capacitySkip
int capacitySkip
-
consumerIndex
java.util.concurrent.atomic.AtomicLong consumerIndex
-
mask
int mask
-
producerIndex
java.util.concurrent.atomic.AtomicLong producerIndex
-
-