Serialized Form
-
Package io.reactivex.rxjava3.exceptions
-
Class io.reactivex.rxjava3.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 io.reactivex.rxjava3.exceptions.MissingBackpressureException extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- 8517344746016032542L
-
Class io.reactivex.rxjava3.exceptions.OnErrorNotImplementedException extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- -6298857009889503852L
-
Class io.reactivex.rxjava3.exceptions.ProtocolViolationException extends java.lang.IllegalStateException implements Serializable
- serialVersionUID:
- 1644750035281290266L
-
Class io.reactivex.rxjava3.exceptions.QueueOverflowException extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- 8517344746016032542L
-
Class io.reactivex.rxjava3.exceptions.UndeliverableException extends java.lang.IllegalStateException implements Serializable
- serialVersionUID:
- 1644750035281290266L
-
-
Package io.reactivex.rxjava3.internal.disposables
-
Class io.reactivex.rxjava3.internal.disposables.ArrayCompositeDisposable extends java.util.concurrent.atomic.AtomicReferenceArray<Disposable> implements Serializable
- serialVersionUID:
- 2746389416410565408L
-
Class io.reactivex.rxjava3.internal.disposables.CancellableDisposable extends java.util.concurrent.atomic.AtomicReference<Cancellable> implements Serializable
- serialVersionUID:
- 5718521705281392066L
-
Class io.reactivex.rxjava3.internal.disposables.SequentialDisposable extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
- serialVersionUID:
- -754898800686245608L
-
-
Package io.reactivex.rxjava3.internal.observers
-
Class io.reactivex.rxjava3.internal.observers.BasicIntQueueDisposable extends java.util.concurrent.atomic.AtomicInteger implements Serializable
- serialVersionUID:
- -1001730202384742097L
-
Class io.reactivex.rxjava3.internal.observers.BiConsumerSingleObserver extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
- serialVersionUID:
- 4943102778943297569L
-
Serialized Fields
-
onCallback
BiConsumer<? super T,? super java.lang.Throwable> onCallback
-
-
Class io.reactivex.rxjava3.internal.observers.BlockingObserver extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
- serialVersionUID:
- -4875965440900746268L
-
Serialized Fields
-
queue
java.util.Queue<java.lang.Object> queue
-
-
Class io.reactivex.rxjava3.internal.observers.CallbackCompletableObserver extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
- serialVersionUID:
- -4361286194466301354L
-
Class io.reactivex.rxjava3.internal.observers.ConsumerSingleObserver extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
- serialVersionUID:
- -7012088219455310787L
-
Class io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable extends BasicIntQueueDisposable<T> implements Serializable
- serialVersionUID:
- -5502432239815349361L
-
Class io.reactivex.rxjava3.internal.observers.DeferredScalarObserver extends DeferredScalarDisposable<R> implements Serializable
- serialVersionUID:
- -266195175408988651L
-
Serialized Fields
-
upstream
Disposable upstream
The upstream disposable.
-
-
Class io.reactivex.rxjava3.internal.observers.DisposableAutoReleaseMultiObserver extends AbstractDisposableAutoRelease implements Serializable
- serialVersionUID:
- 8924480688481408726L
-
Class io.reactivex.rxjava3.internal.observers.DisposableAutoReleaseObserver extends AbstractDisposableAutoRelease implements Serializable
- serialVersionUID:
- 8924480688481408726L
-
Class io.reactivex.rxjava3.internal.observers.EmptyCompletableObserver extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
- serialVersionUID:
- -7545121636549663526L
-
Class io.reactivex.rxjava3.internal.observers.ForEachWhileObserver extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
- serialVersionUID:
- -4403180040475402120L
-
Class io.reactivex.rxjava3.internal.observers.InnerQueuedObserver extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
- serialVersionUID:
- -5417183359794346637L
-
Serialized Fields
-
done
boolean done
-
fusionMode
int fusionMode
-
parent
InnerQueuedObserverSupport<T> parent
-
prefetch
int prefetch
-
queue
SimpleQueue<T> queue
-
-
Class io.reactivex.rxjava3.internal.observers.LambdaObserver extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
- serialVersionUID:
- -7251123623727029452L
-
-
Package io.reactivex.rxjava3.internal.operators.flowable
-
Class io.reactivex.rxjava3.internal.operators.flowable.FlowableGroupBy.GroupBySubscriber extends java.util.concurrent.atomic.AtomicLong implements Serializable
- serialVersionUID:
- -3688291656102519502L
-
Serialized Fields
-
bufferSize
int bufferSize
-
cancelled
java.util.concurrent.atomic.AtomicBoolean cancelled
-
delayError
boolean delayError
-
done
boolean done
-
downstream
org.reactivestreams.Subscriber<? super GroupedFlowable<K,V>> downstream
-
emittedGroups
long emittedGroups
-
evictedGroups
java.util.Queue<FlowableGroupBy.GroupedUnicast<K,V>> evictedGroups
-
groupConsumed
java.util.concurrent.atomic.AtomicLong groupConsumed
-
groupCount
java.util.concurrent.atomic.AtomicInteger groupCount
-
groups
java.util.Map<java.lang.Object,FlowableGroupBy.GroupedUnicast<K,V>> groups
-
keySelector
Function<? super T,? extends K> keySelector
-
limit
int limit
-
upstream
org.reactivestreams.Subscription upstream
-
valueSelector
Function<? super T,? extends V> valueSelector
-
-
-
Package io.reactivex.rxjava3.internal.operators.maybe
-
Class io.reactivex.rxjava3.internal.operators.maybe.MaybeCallbackObserver extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
- serialVersionUID:
- -6076952298809384986L
-
-
Package io.reactivex.rxjava3.internal.operators.mixed
-
Class io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver extends java.util.concurrent.atomic.AtomicInteger implements Serializable
- serialVersionUID:
- -3214213361171757852L
-
Serialized Fields
-
disposed
boolean disposed
-
done
boolean done
-
errorMode
ErrorMode errorMode
-
errors
AtomicThrowable errors
-
prefetch
int prefetch
-
queue
SimpleQueue<T> queue
-
upstream
Disposable upstream
-
-
Class io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainSubscriber extends java.util.concurrent.atomic.AtomicInteger implements Serializable
- serialVersionUID:
- -3214213361171757852L
-
Serialized Fields
-
cancelled
boolean cancelled
-
done
boolean done
-
errorMode
ErrorMode errorMode
-
errors
AtomicThrowable errors
-
prefetch
int prefetch
-
queue
SimpleQueue<T> queue
-
syncFused
boolean syncFused
-
upstream
org.reactivestreams.Subscription upstream
-
-
-
Package io.reactivex.rxjava3.internal.operators.observable
-
Class io.reactivex.rxjava3.internal.operators.observable.ObservableGroupBy.GroupByObserver extends java.util.concurrent.atomic.AtomicInteger implements Serializable
- serialVersionUID:
- -3688291656102519502L
-
Serialized Fields
-
bufferSize
int bufferSize
-
cancelled
java.util.concurrent.atomic.AtomicBoolean cancelled
-
delayError
boolean delayError
-
downstream
Observer<? super GroupedObservable<K,V>> downstream
-
groups
java.util.Map<java.lang.Object,ObservableGroupBy.GroupedUnicast<K,V>> groups
-
keySelector
Function<? super T,? extends K> keySelector
-
upstream
Disposable upstream
-
valueSelector
Function<? super T,? extends V> valueSelector
-
-
Class io.reactivex.rxjava3.internal.operators.observable.ObservableScalarXMap.ScalarDisposable extends java.util.concurrent.atomic.AtomicInteger implements Serializable
- serialVersionUID:
- 3880992722410194083L
-
Class io.reactivex.rxjava3.internal.operators.observable.ObserverResourceWrapper extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
- serialVersionUID:
- -8612022020200669122L
-
Serialized Fields
-
downstream
Observer<? super T> downstream
-
upstream
java.util.concurrent.atomic.AtomicReference<Disposable> upstream
-
-
-
Package io.reactivex.rxjava3.internal.schedulers
-
Class io.reactivex.rxjava3.internal.schedulers.RxThreadFactory extends java.util.concurrent.atomic.AtomicLong implements Serializable
- serialVersionUID:
- -7789753024099756196L
-
Serialized Fields
-
nonBlocking
boolean nonBlocking
-
prefix
java.lang.String prefix
-
priority
int priority
-
-
Class io.reactivex.rxjava3.internal.schedulers.ScheduledDirectPeriodicTask extends AbstractDirectTask implements Serializable
- serialVersionUID:
- 1811839108042568751L
-
Class io.reactivex.rxjava3.internal.schedulers.ScheduledDirectTask extends AbstractDirectTask implements Serializable
- serialVersionUID:
- 1811839108042568751L
-
Class io.reactivex.rxjava3.internal.schedulers.ScheduledRunnable extends java.util.concurrent.atomic.AtomicReferenceArray<java.lang.Object> implements Serializable
- serialVersionUID:
- -6120223772001106981L
-
Serialized Fields
-
actual
java.lang.Runnable actual
-
interruptOnCancel
boolean interruptOnCancel
-
-
-
Package io.reactivex.rxjava3.internal.subscribers
-
Class io.reactivex.rxjava3.internal.subscribers.BlockingSubscriber extends java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> implements Serializable
- serialVersionUID:
- -4875965440900746268L
-
Serialized Fields
-
queue
java.util.Queue<java.lang.Object> queue
-
-
Class io.reactivex.rxjava3.internal.subscribers.BoundedSubscriber extends java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> implements Serializable
- serialVersionUID:
- -7251123623727029452L
-
Class io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber extends DeferredScalarSubscription<R> implements Serializable
- serialVersionUID:
- 2984505488220891551L
-
Serialized Fields
-
hasValue
boolean hasValue
Can indicate if there was at least on onNext call. -
upstream
org.reactivestreams.Subscription upstream
The upstream subscription.
-
-
Class io.reactivex.rxjava3.internal.subscribers.DisposableAutoReleaseSubscriber extends java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> implements Serializable
- serialVersionUID:
- 8924480688481408726L
-
Serialized Fields
-
composite
java.util.concurrent.atomic.AtomicReference<DisposableContainer> composite
-
onComplete
Action onComplete
-
onError
Consumer<? super java.lang.Throwable> onError
-
onNext
Consumer<? super T> onNext
-
-
Class io.reactivex.rxjava3.internal.subscribers.ForEachWhileSubscriber extends java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> implements Serializable
- serialVersionUID:
- -4403180040475402120L
-
Class io.reactivex.rxjava3.internal.subscribers.InnerQueuedSubscriber extends java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> implements Serializable
- serialVersionUID:
- 22876611072430776L
-
Serialized Fields
-
done
boolean done
-
fusionMode
int fusionMode
-
limit
int limit
-
parent
InnerQueuedSubscriberSupport<T> parent
-
prefetch
int prefetch
-
produced
long produced
-
queue
SimpleQueue<T> queue
-
-
Class io.reactivex.rxjava3.internal.subscribers.LambdaSubscriber extends java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> implements Serializable
- serialVersionUID:
- -7251123623727029452L
-
Class io.reactivex.rxjava3.internal.subscribers.SinglePostCompleteSubscriber extends java.util.concurrent.atomic.AtomicLong implements Serializable
- serialVersionUID:
- 7917814472626990048L
-
Serialized Fields
-
Class io.reactivex.rxjava3.internal.subscribers.StrictSubscriber extends java.util.concurrent.atomic.AtomicInteger implements Serializable
- serialVersionUID:
- -4945028590049415624L
-
Serialized Fields
-
done
boolean done
-
downstream
org.reactivestreams.Subscriber<? super T> downstream
-
error
AtomicThrowable error
-
once
java.util.concurrent.atomic.AtomicBoolean once
-
requested
java.util.concurrent.atomic.AtomicLong requested
-
upstream
java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> upstream
-
-
Class io.reactivex.rxjava3.internal.subscribers.SubscriberResourceWrapper extends java.util.concurrent.atomic.AtomicReference<Disposable> implements Serializable
- serialVersionUID:
- -8612022020200669122L
-
Serialized Fields
-
downstream
org.reactivestreams.Subscriber<? super T> downstream
-
upstream
java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> upstream
-
-
-
Package io.reactivex.rxjava3.internal.subscriptions
-
Class io.reactivex.rxjava3.internal.subscriptions.ArrayCompositeSubscription extends java.util.concurrent.atomic.AtomicReferenceArray<org.reactivestreams.Subscription> implements Serializable
- serialVersionUID:
- 2746389416410565408L
-
Class io.reactivex.rxjava3.internal.subscriptions.AsyncSubscription extends java.util.concurrent.atomic.AtomicLong implements Serializable
- serialVersionUID:
- 7028635084060361255L
-
Serialized Fields
-
actual
java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> actual
-
resource
java.util.concurrent.atomic.AtomicReference<Disposable> resource
-
-
Class io.reactivex.rxjava3.internal.subscriptions.BasicIntQueueSubscription extends java.util.concurrent.atomic.AtomicInteger implements Serializable
- serialVersionUID:
- -6671519529404341862L
-
Class io.reactivex.rxjava3.internal.subscriptions.BasicQueueSubscription extends java.util.concurrent.atomic.AtomicLong implements Serializable
- serialVersionUID:
- -6671519529404341862L
-
Class io.reactivex.rxjava3.internal.subscriptions.BooleanSubscription extends java.util.concurrent.atomic.AtomicBoolean implements Serializable
- serialVersionUID:
- -8127758972444290902L
-
Class io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription extends BasicIntQueueSubscription<T> implements Serializable
- serialVersionUID:
- -2151279923272604993L
-
Class io.reactivex.rxjava3.internal.subscriptions.ScalarSubscription extends java.util.concurrent.atomic.AtomicInteger implements Serializable
- serialVersionUID:
- -3830916580126663321L
-
Class io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter extends java.util.concurrent.atomic.AtomicInteger implements Serializable
- serialVersionUID:
- -2189523197179400958L
-
Serialized Fields
-
actual
org.reactivestreams.Subscription actual
The current subscription which may null if no Subscriptions have been set. -
cancelled
boolean cancelled
-
cancelOnReplace
boolean cancelOnReplace
-
missedProduced
java.util.concurrent.atomic.AtomicLong missedProduced
-
missedRequested
java.util.concurrent.atomic.AtomicLong missedRequested
-
missedSubscription
java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> missedSubscription
-
requested
long requested
The current outstanding request amount. -
unbounded
boolean unbounded
-
-
-
Package io.reactivex.rxjava3.internal.util
-
Class io.reactivex.rxjava3.internal.util.AtomicThrowable extends java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> implements Serializable
- serialVersionUID:
- 3949248817947090603L
-
Class io.reactivex.rxjava3.internal.util.VolatileSizeArrayList extends java.util.concurrent.atomic.AtomicInteger implements Serializable
- serialVersionUID:
- 3972397474470203923L
-
Serialized Fields
-
list
java.util.ArrayList<T> list
-
-
-
Package io.reactivex.rxjava3.operators
-
Class io.reactivex.rxjava3.operators.SpscArrayQueue extends java.util.concurrent.atomic.AtomicReferenceArray<E> implements Serializable
- serialVersionUID:
- -1296597691183856449L
-
Serialized Fields
-
consumerIndex
java.util.concurrent.atomic.AtomicLong consumerIndex
-
lookAheadStep
int lookAheadStep
-
mask
int mask
-
producerIndex
java.util.concurrent.atomic.AtomicLong producerIndex
-
producerLookAhead
long producerLookAhead
-
-