Serialized Form

Class rx.exceptions.CompositeException extends RuntimeException implements Serializable

serialVersionUID:

3026362227162912146L

• Serialized Fields

  • exceptions

    List<E> exceptions

  • message

    String message

  • cause

    Throwable cause

Class rx.exceptions.MissingBackpressureException extends Exception implements Serializable

serialVersionUID:

7250870679677032194L

Class rx.exceptions.OnCompletedFailedException extends RuntimeException implements Serializable

serialVersionUID:

8622579378868820554L

Class rx.exceptions.OnErrorFailedException extends RuntimeException implements Serializable

serialVersionUID:

-419289748403337611L

Class rx.exceptions.OnErrorNotImplementedException extends RuntimeException implements Serializable

serialVersionUID:

-6298857009889503852L

Class rx.exceptions.OnErrorThrowable extends RuntimeException implements Serializable

serialVersionUID:

-569558213262703934L

• Serialized Fields

  • hasValue

    boolean hasValue

  • value

    Object value

Class rx.exceptions.OnErrorThrowable.OnNextValue extends RuntimeException implements Serializable

serialVersionUID:

-3454462756050397899L

• Serialized Fields

  • value

    Object value

Class rx.exceptions.UnsubscribeFailedException extends RuntimeException implements Serializable

serialVersionUID:

4594672310593167598L

Class rx.internal.producers.QueuedProducer extends AtomicLong implements Serializable

serialVersionUID:

7277121710709137047L

• Serialized Fields

  • child

    Subscriber<T> child

  • queue

    Queue<E> queue

  • wip

    AtomicInteger wip

  • error

    Throwable error

  • done

    boolean done

Class rx.internal.producers.QueuedValueProducer extends AtomicLong implements Serializable

serialVersionUID:

7277121710709137047L

• Serialized Fields

  • child

    Subscriber<T> child

  • queue

    Queue<E> queue

  • wip

    AtomicInteger wip

Class rx.internal.producers.SingleDelayedProducer extends AtomicInteger implements Serializable

serialVersionUID:

-2873467947112093874L

• Serialized Fields

  • child

    Subscriber<T> child

    The child to emit the value and completion once possible.

  • value

    Object value

    The value to emit.

Class rx.internal.producers.SingleProducer extends AtomicBoolean implements Serializable

serialVersionUID:

-3353584923995471404L

• Serialized Fields

  • child

    Subscriber<T> child

    The child subscriber.

  • value

    Object value

    The value to be emitted.

Class rx.internal.schedulers.ScheduledAction extends AtomicReference<Thread> implements Serializable

serialVersionUID:

-3962399486978279857L

• Serialized Fields

  • cancel

    SubscriptionList cancel

  • action

    Action0 action

Class rx.internal.util.BackpressureDrainManager extends AtomicLong implements Serializable

• Serialized Fields

  • emitting

    boolean emitting

    Indicates if one is in emitting phase, guarded by this.

  • terminated

    boolean terminated

    Indicates a terminal state.

  • exception

    Throwable exception

    Indicates an error state, barrier is provided via terminated.

  • actual

    BackpressureDrainManager.BackpressureQueueCallback actual

    The callbacks to manage the drain.

Class rx.internal.util.RxThreadFactory extends AtomicLong implements Serializable

• Serialized Fields

  • prefix

    String prefix

Class rx.internal.util.atomic.LinkedQueueNode extends AtomicReference<LinkedQueueNode<E>> implements Serializable

serialVersionUID:

2404266111789071508L

• Serialized Fields

  • value

    Object value

Class rx.internal.util.atomic.SpscExactAtomicArrayQueue extends AtomicReferenceArray<T> implements Serializable

serialVersionUID:

6210984603741293445L

• Serialized Fields

  • mask

    int mask

  • capacitySkip

    int capacitySkip

  • producerIndex

    long producerIndex

  • consumerIndex

    long consumerIndex