Serialized Form (rxjava2-backport 2.0.0-RC2 API)

Package hu.akarnokd.rxjava2.exceptions
- Class hu.akarnokd.rxjava2.exceptions.CompositeException extends java.lang.RuntimeException implements Serializable
  
  serialVersionUID:
  
  2004635183691362481L
  - Serialized Fields
    - suppressed
```
java.util.List<E> suppressed
```
- Class hu.akarnokd.rxjava2.exceptions.MissingBackpressureException extends java.lang.RuntimeException implements Serializable
  
  serialVersionUID:
  
  8517344746016032542L
- Class hu.akarnokd.rxjava2.exceptions.OnCompleteFailedException extends java.lang.RuntimeException implements Serializable
  
  serialVersionUID:
  
  -6179993283427447098L
- Class hu.akarnokd.rxjava2.exceptions.OnErrorFailedException extends java.lang.RuntimeException implements Serializable
  
  serialVersionUID:
  
  2656125445290831911L
- Class hu.akarnokd.rxjava2.exceptions.OnErrorNotImplementedException extends java.lang.RuntimeException implements Serializable
  
  serialVersionUID:
  
  -3698670655303683299L
- Class hu.akarnokd.rxjava2.exceptions.UnsubscribeFailedException extends java.lang.RuntimeException implements Serializable
  
  serialVersionUID:
  
  8947024194181365640L
Package hu.akarnokd.rxjava2.internal.disposables
- Class hu.akarnokd.rxjava2.internal.disposables.ArrayCompositeResource extends java.util.concurrent.atomic.AtomicReferenceArray<java.lang.Object> implements Serializable
  
  serialVersionUID:
  
  2746389416410565408L
  - Serialized Fields
    - disposer
```
Consumer<T> disposer
```
- Class hu.akarnokd.rxjava2.internal.disposables.MultipleAssignmentResource extends java.util.concurrent.atomic.AtomicReference<java.lang.Object> implements Serializable
  
  serialVersionUID:
  
  5247635821051810205L
  - Serialized Fields
    - disposer
```
Consumer<T> disposer
```
      The callback to dispose the resource.
- Class hu.akarnokd.rxjava2.internal.disposables.SerialResource extends java.util.concurrent.atomic.AtomicReference<java.lang.Object> implements Serializable
  
  serialVersionUID:
  
  5247635821051810205L
  - Serialized Fields
    - disposer
```
Consumer<T> disposer
```
      The callback to dispose the resource.
Package hu.akarnokd.rxjava2.internal.operators
- Class hu.akarnokd.rxjava2.internal.operators.OperatorGroupBy.GroupBySubscriber extends java.util.concurrent.atomic.AtomicInteger implements Serializable
  
  serialVersionUID:
  
  -3688291656102519502L
  - Serialized Fields
    - actual
```
org.reactivestreams.Subscriber<T> actual
```
    - keySelector
```
Function<T,R> keySelector
```
    - valueSelector
```
Function<T,R> valueSelector
```
    - bufferSize
```
int bufferSize
```
    - delayError
```
boolean delayError
```
    - groups
```
java.util.Map<K,V> groups
```
    - queue
```
java.util.Queue<E> queue
```
    - s
```
org.reactivestreams.Subscription s
```
    - cancelled
```
int cancelled
```
    - requested
```
long requested
```
    - groupCount
```
int groupCount
```
    - error
```
java.lang.Throwable error
```
    - done
```
boolean done
```
- Class hu.akarnokd.rxjava2.internal.operators.PublisherIterableSource extends java.util.concurrent.atomic.AtomicBoolean implements Serializable
  
  serialVersionUID:
  
  9051303031779816842L
  - Serialized Fields
    - source
```
java.lang.Iterable<T> source
```
- Class hu.akarnokd.rxjava2.internal.operators.SubscriberResourceWrapper extends java.util.concurrent.atomic.AtomicReference<java.lang.Object> implements Serializable
  
  serialVersionUID:
  
  -8612022020200669122L
  - Serialized Fields
    - actual
```
org.reactivestreams.Subscriber<T> actual
```
    - disposer
```
Consumer<T> disposer
```
    - subscription
```
org.reactivestreams.Subscription subscription
```
Package hu.akarnokd.rxjava2.internal.operators.nbp
- Class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorGroupBy.GroupBySubscriber extends java.util.concurrent.atomic.AtomicInteger implements Serializable
  
  serialVersionUID:
  
  -3688291656102519502L
  - Serialized Fields
    - actual
```
NbpObservable.NbpSubscriber<T> actual
```
    - keySelector
```
Function<T,R> keySelector
```
    - valueSelector
```
Function<T,R> valueSelector
```
    - bufferSize
```
int bufferSize
```
    - delayError
```
boolean delayError
```
    - groups
```
java.util.Map<K,V> groups
```
    - s
```
Disposable s
```
    - cancelled
```
int cancelled
```
- Class hu.akarnokd.rxjava2.internal.operators.nbp.NbpSubscriberResourceWrapper extends java.util.concurrent.atomic.AtomicReference<java.lang.Object> implements Serializable
  
  serialVersionUID:
  
  -8612022020200669122L
  - Serialized Fields
    - actual
```
NbpObservable.NbpSubscriber<T> actual
```
    - disposer
```
Consumer<T> disposer
```
    - subscription
```
Disposable subscription
```
Package hu.akarnokd.rxjava2.internal.queue
- Class hu.akarnokd.rxjava2.internal.queue.LinkedQueueNode extends java.util.concurrent.atomic.AtomicReference<LinkedQueueNode<E>> implements Serializable
  
  serialVersionUID:
  
  2404266111789071508L
  - Serialized Fields
    - value
```
java.lang.Object value
```
- Class hu.akarnokd.rxjava2.internal.queue.SpscArrayQueue extends hu.akarnokd.rxjava2.internal.queue.BaseArrayQueue<E> implements Serializable
  
  serialVersionUID:
  
  -1296597691183856449L
  - Serialized Fields
    - producerIndex
```
java.util.concurrent.atomic.AtomicLong producerIndex
```
    - producerLookAhead
```
long producerLookAhead
```
    - consumerIndex
```
java.util.concurrent.atomic.AtomicLong consumerIndex
```
    - lookAheadStep
```
int lookAheadStep
```
- Class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue extends java.util.concurrent.atomic.AtomicReferenceArray<T> implements Serializable
  
  serialVersionUID:
  
  6210984603741293445L
  - Serialized Fields
    - mask
```
int mask
```
    - capacitySkip
```
int capacitySkip
```
    - producerIndex
```
long producerIndex
```
    - consumerIndex
```
long consumerIndex
```
Package hu.akarnokd.rxjava2.internal.schedulers
- Class hu.akarnokd.rxjava2.internal.schedulers.RxThreadFactory extends java.util.concurrent.atomic.AtomicLong implements Serializable
  
  serialVersionUID:
  
  -7789753024099756196L
  - Serialized Fields
    - prefix
```
java.lang.String prefix
```
- Class hu.akarnokd.rxjava2.internal.schedulers.ScheduledRunnable extends java.util.concurrent.atomic.AtomicReferenceArray<java.lang.Object> implements Serializable
  
  serialVersionUID:
  
  -6120223772001106981L
  - Serialized Fields
    - actual
```
java.lang.Runnable actual
```
Package hu.akarnokd.rxjava2.internal.subscribers
- Class hu.akarnokd.rxjava2.internal.subscribers.BlockingSubscriber extends java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> implements Serializable
  
  serialVersionUID:
  
  -4875965440900746268L
  - Serialized Fields
    - queue
```
java.util.Queue<E> queue
```
- Class hu.akarnokd.rxjava2.internal.subscribers.LambdaSubscriber extends java.util.concurrent.atomic.AtomicReference<java.lang.Object> implements Serializable
  
  serialVersionUID:
  
  -7251123623727029452L
  - Serialized Fields
    - onNext
```
Consumer<T> onNext
```
    - onError
```
Consumer<T> onError
```
    - onComplete
```
java.lang.Runnable onComplete
```
    - onSubscribe
```
Consumer<T> onSubscribe
```
Package hu.akarnokd.rxjava2.internal.subscribers.nbp
- Class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpBlockingSubscriber extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
  
  serialVersionUID:
  
  -4875965440900746268L
  - Serialized Fields
    - queue
```
java.util.Queue<E> queue
```
- Class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpLambdaSubscriber extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
  
  serialVersionUID:
  
  -7251123623727029452L
  - Serialized Fields
    - onNext
```
Consumer<T> onNext
```
    - onError
```
Consumer<T> onError
```
    - onComplete
```
java.lang.Runnable onComplete
```
    - onSubscribe
```
Consumer<T> onSubscribe
```
Package hu.akarnokd.rxjava2.internal.subscriptions
- Class hu.akarnokd.rxjava2.internal.subscriptions.AsyncSubscription extends java.util.concurrent.atomic.AtomicLong implements Serializable
  
  serialVersionUID:
  
  7028635084060361255L
  - Serialized Fields
    - actual
```
org.reactivestreams.Subscription actual
```
    - resource
```
Disposable resource
```
- Class hu.akarnokd.rxjava2.internal.subscriptions.BooleanSubscription extends java.util.concurrent.atomic.AtomicBoolean implements Serializable
  
  serialVersionUID:
  
  -8127758972444290902L
- Class hu.akarnokd.rxjava2.internal.subscriptions.DisposableSubscription extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
  
  serialVersionUID:
  
  -2358839743797425727L
- Class hu.akarnokd.rxjava2.internal.subscriptions.ScalarAsyncSubscription extends java.util.concurrent.atomic.AtomicInteger implements Serializable
  
  serialVersionUID:
  
  -7135031000854703151L
  - Serialized Fields
    - value
```
java.lang.Object value
```
    - subscriber
```
org.reactivestreams.Subscriber<T> subscriber
```
- Class hu.akarnokd.rxjava2.internal.subscriptions.ScalarSubscription extends java.util.concurrent.atomic.AtomicBoolean implements Serializable
  
  serialVersionUID:
  
  -3830916580126663321L
  - Serialized Fields
    - value
```
java.lang.Object value
```
      The single value to emit, set to null.
    - subscriber
```
org.reactivestreams.Subscriber<T> subscriber
```
      The actual subscriber.
- Class hu.akarnokd.rxjava2.internal.subscriptions.SubscriptionArbiter extends java.util.concurrent.atomic.AtomicInteger implements Serializable
  
  serialVersionUID:
  
  -2189523197179400958L
  - Serialized Fields
    - missedSubscription
```
java.util.Queue<E> missedSubscription
```
    - actual
```
org.reactivestreams.Subscription actual
```
    - requested
```
long requested
```
    - cancelled
```
boolean cancelled
```
    - missedRequested
```
long missedRequested
```
    - missedProduced
```
long missedProduced
```

Serialized Form

Package hu.akarnokd.rxjava2.exceptions

Class hu.akarnokd.rxjava2.exceptions.CompositeException extends java.lang.RuntimeException implements Serializable

Serialized Fields

suppressed

Class hu.akarnokd.rxjava2.exceptions.MissingBackpressureException extends java.lang.RuntimeException implements Serializable

Class hu.akarnokd.rxjava2.exceptions.OnCompleteFailedException extends java.lang.RuntimeException implements Serializable

Class hu.akarnokd.rxjava2.exceptions.OnErrorFailedException extends java.lang.RuntimeException implements Serializable

Class hu.akarnokd.rxjava2.exceptions.OnErrorNotImplementedException extends java.lang.RuntimeException implements Serializable

Class hu.akarnokd.rxjava2.exceptions.UnsubscribeFailedException extends java.lang.RuntimeException implements Serializable

Package hu.akarnokd.rxjava2.internal.disposables

Class hu.akarnokd.rxjava2.internal.disposables.ArrayCompositeResource extends java.util.concurrent.atomic.AtomicReferenceArray<java.lang.Object> implements Serializable

Serialized Fields

disposer

Class hu.akarnokd.rxjava2.internal.disposables.MultipleAssignmentResource extends java.util.concurrent.atomic.AtomicReference<java.lang.Object> implements Serializable

Serialized Fields

disposer

Class hu.akarnokd.rxjava2.internal.disposables.SerialResource extends java.util.concurrent.atomic.AtomicReference<java.lang.Object> implements Serializable

Serialized Fields

disposer

Package hu.akarnokd.rxjava2.internal.operators

Class hu.akarnokd.rxjava2.internal.operators.OperatorGroupBy.GroupBySubscriber extends java.util.concurrent.atomic.AtomicInteger implements Serializable

Serialized Fields

actual

keySelector

valueSelector

bufferSize

delayError

groups

queue

s

cancelled

requested

groupCount

error

done

Class hu.akarnokd.rxjava2.internal.operators.PublisherIterableSource extends java.util.concurrent.atomic.AtomicBoolean implements Serializable

Serialized Fields

source

Class hu.akarnokd.rxjava2.internal.operators.SubscriberResourceWrapper extends java.util.concurrent.atomic.AtomicReference<java.lang.Object> implements Serializable

Serialized Fields

actual

disposer

subscription

Package hu.akarnokd.rxjava2.internal.operators.nbp

Class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorGroupBy.GroupBySubscriber extends java.util.concurrent.atomic.AtomicInteger implements Serializable

Serialized Fields

actual

keySelector

valueSelector

bufferSize

delayError

groups

s

cancelled

Class hu.akarnokd.rxjava2.internal.operators.nbp.NbpSubscriberResourceWrapper extends java.util.concurrent.atomic.AtomicReference<java.lang.Object> implements Serializable

Serialized Fields

actual

disposer

subscription

Package hu.akarnokd.rxjava2.internal.queue

Class hu.akarnokd.rxjava2.internal.queue.LinkedQueueNode extends java.util.concurrent.atomic.AtomicReference<LinkedQueueNode<E>> implements Serializable

Serialized Fields

value

Class hu.akarnokd.rxjava2.internal.queue.SpscArrayQueue extends hu.akarnokd.rxjava2.internal.queue.BaseArrayQueue<E> implements Serializable

Serialized Fields

producerIndex

producerLookAhead

consumerIndex

lookAheadStep

Class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue extends java.util.concurrent.atomic.AtomicReferenceArray<T> implements Serializable

Serialized Fields

mask

capacitySkip

producerIndex

consumerIndex

Package hu.akarnokd.rxjava2.internal.schedulers

Class hu.akarnokd.rxjava2.internal.schedulers.RxThreadFactory extends java.util.concurrent.atomic.AtomicLong implements Serializable

Serialized Fields

prefix