Serialized Form
-
Package io.reactivex.rxjava3.exceptions
-
Exception Class io.reactivex.rxjava3.exceptions.CompositeException
class CompositeException extends RuntimeException implements Serializable- serialVersionUID:
- 3026362227162912146L
-
Exception Class io.reactivex.rxjava3.exceptions.MissingBackpressureException
class MissingBackpressureException extends RuntimeException implements Serializable- serialVersionUID:
- 8517344746016032542L
-
Exception Class io.reactivex.rxjava3.exceptions.OnErrorNotImplementedException
class OnErrorNotImplementedException extends RuntimeException implements Serializable- serialVersionUID:
- -6298857009889503852L
-
Exception Class io.reactivex.rxjava3.exceptions.ProtocolViolationException
class ProtocolViolationException extends IllegalStateException implements Serializable- serialVersionUID:
- 1644750035281290266L
-
Exception Class io.reactivex.rxjava3.exceptions.QueueOverflowException
class QueueOverflowException extends RuntimeException implements Serializable- serialVersionUID:
- 8517344746016032542L
-
Exception Class io.reactivex.rxjava3.exceptions.UndeliverableException
class UndeliverableException extends IllegalStateException implements Serializable- serialVersionUID:
- 1644750035281290266L
-
-
Package io.reactivex.rxjava3.internal.disposables
-
Class io.reactivex.rxjava3.internal.disposables.ArrayCompositeDisposable
- serialVersionUID:
- 2746389416410565408L
-
Class io.reactivex.rxjava3.internal.disposables.CancellableDisposable
- serialVersionUID:
- 5718521705281392066L
-
Class io.reactivex.rxjava3.internal.disposables.SequentialDisposable
- serialVersionUID:
- -754898800686245608L
-
-
Package io.reactivex.rxjava3.internal.observers
-
Class io.reactivex.rxjava3.internal.observers.BasicIntQueueDisposable
class BasicIntQueueDisposable extends AtomicInteger implements Serializable- serialVersionUID:
- -1001730202384742097L
-
Class io.reactivex.rxjava3.internal.observers.BiConsumerSingleObserver
- serialVersionUID:
- 4943102778943297569L
-
Serialized Fields
-
onCallback
BiConsumer<? super T,
? super Throwable> onCallback
-
-
Class io.reactivex.rxjava3.internal.observers.BlockingObserver
- serialVersionUID:
- -4875965440900746268L
-
Class io.reactivex.rxjava3.internal.observers.CallbackCompletableObserver
- serialVersionUID:
- -4361286194466301354L
-
Class io.reactivex.rxjava3.internal.observers.ConsumerSingleObserver
- serialVersionUID:
- -7012088219455310787L
-
Class io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable
- serialVersionUID:
- -5502432239815349361L
-
Class io.reactivex.rxjava3.internal.observers.DeferredScalarObserver
- serialVersionUID:
- -266195175408988651L
-
Serialized Fields
-
upstream
Disposable upstream
The upstream disposable.
-
-
Class io.reactivex.rxjava3.internal.observers.DisposableAutoReleaseMultiObserver
class DisposableAutoReleaseMultiObserver extends AbstractDisposableAutoRelease implements Serializable- serialVersionUID:
- 8924480688481408726L
-
Class io.reactivex.rxjava3.internal.observers.DisposableAutoReleaseObserver
class DisposableAutoReleaseObserver extends AbstractDisposableAutoRelease implements Serializable- serialVersionUID:
- 8924480688481408726L
-
Class io.reactivex.rxjava3.internal.observers.EmptyCompletableObserver
- serialVersionUID:
- -7545121636549663526L
-
Class io.reactivex.rxjava3.internal.observers.ForEachWhileObserver
- serialVersionUID:
- -4403180040475402120L
-
Class io.reactivex.rxjava3.internal.observers.InnerQueuedObserver
- 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
- serialVersionUID:
- -7251123623727029452L
-
-
Package io.reactivex.rxjava3.internal.operators.flowable
-
Class io.reactivex.rxjava3.internal.operators.flowable.FlowableGroupBy.GroupBySubscriber
class GroupBySubscriber extends AtomicLong implements Serializable- serialVersionUID:
- -3688291656102519502L
-
Serialized Fields
-
bufferSize
int bufferSize
-
cancelled
AtomicBoolean cancelled
-
delayError
boolean delayError
-
done
boolean done
-
downstream
org.reactivestreams.Subscriber<? super GroupedFlowable<K,
V>> downstream -
emittedGroups
long emittedGroups
-
evictedGroups
Queue<FlowableGroupBy.GroupedUnicast<K,
V>> evictedGroups -
groupConsumed
AtomicLong groupConsumed
-
groupCount
AtomicInteger groupCount
-
groups
Map<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
-
Package io.reactivex.rxjava3.internal.operators.mixed
-
Class io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver
class ConcatMapXMainObserver extends 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
class ConcatMapXMainSubscriber extends 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
class GroupByObserver extends AtomicInteger implements Serializable- serialVersionUID:
- -3688291656102519502L
-
Serialized Fields
-
bufferSize
int bufferSize
-
cancelled
AtomicBoolean cancelled
-
delayError
boolean delayError
-
downstream
Observer<? super GroupedObservable<K,
V>> downstream -
groups
Map<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
class ScalarDisposable extends AtomicInteger implements Serializable- serialVersionUID:
- 3880992722410194083L
-
Class io.reactivex.rxjava3.internal.operators.observable.ObserverResourceWrapper
- serialVersionUID:
- -8612022020200669122L
-
Serialized Fields
-
downstream
Observer<? super T> downstream
-
upstream
AtomicReference<Disposable> upstream
-
-
-
Package io.reactivex.rxjava3.internal.schedulers
-
Class io.reactivex.rxjava3.internal.schedulers.RxThreadFactory
class RxThreadFactory extends AtomicLong implements Serializable- serialVersionUID:
- -7789753024099756196L
-
Serialized Fields
-
nonBlocking
boolean nonBlocking
-
prefix
String prefix
-
priority
int priority
-
-
Class io.reactivex.rxjava3.internal.schedulers.ScheduledDirectPeriodicTask
class ScheduledDirectPeriodicTask extends AbstractDirectTask implements Serializable- serialVersionUID:
- 1811839108042568751L
-
Class io.reactivex.rxjava3.internal.schedulers.ScheduledDirectTask
class ScheduledDirectTask extends AbstractDirectTask implements Serializable- serialVersionUID:
- 1811839108042568751L
-
Class io.reactivex.rxjava3.internal.schedulers.ScheduledRunnable
- serialVersionUID:
- -6120223772001106981L
-
Serialized Fields
-
actual
Runnable actual
-
interruptOnCancel
boolean interruptOnCancel
-
-
-
Package io.reactivex.rxjava3.internal.subscribers
-
Class io.reactivex.rxjava3.internal.subscribers.BlockingSubscriber
class BlockingSubscriber extends AtomicReference<org.reactivestreams.Subscription> implements Serializable- serialVersionUID:
- -4875965440900746268L
-
Class io.reactivex.rxjava3.internal.subscribers.BoundedSubscriber
class BoundedSubscriber extends AtomicReference<org.reactivestreams.Subscription> implements Serializable- serialVersionUID:
- -7251123623727029452L
-
Class io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber
- 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
class DisposableAutoReleaseSubscriber extends AtomicReference<org.reactivestreams.Subscription> implements Serializable- serialVersionUID:
- 8924480688481408726L
-
Serialized Fields
-
composite
AtomicReference<DisposableContainer> composite
-
onComplete
Action onComplete
-
onError
Consumer<? super Throwable> onError
-
onNext
Consumer<? super T> onNext
-
-
Class io.reactivex.rxjava3.internal.subscribers.ForEachWhileSubscriber
class ForEachWhileSubscriber extends AtomicReference<org.reactivestreams.Subscription> implements Serializable- serialVersionUID:
- -4403180040475402120L
-
Class io.reactivex.rxjava3.internal.subscribers.InnerQueuedSubscriber
class InnerQueuedSubscriber extends 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
class LambdaSubscriber extends AtomicReference<org.reactivestreams.Subscription> implements Serializable- serialVersionUID:
- -7251123623727029452L
-
Class io.reactivex.rxjava3.internal.subscribers.SinglePostCompleteSubscriber
class SinglePostCompleteSubscriber extends AtomicLong implements Serializable- serialVersionUID:
- 7917814472626990048L
-
Serialized Fields
-
Class io.reactivex.rxjava3.internal.subscribers.StrictSubscriber
class StrictSubscriber extends AtomicInteger implements Serializable- serialVersionUID:
- -4945028590049415624L
-
Serialized Fields
-
done
boolean done
-
downstream
org.reactivestreams.Subscriber<? super T> downstream
-
error
AtomicThrowable error
-
once
AtomicBoolean once
-
requested
AtomicLong requested
-
upstream
AtomicReference<org.reactivestreams.Subscription> upstream
-
-
Class io.reactivex.rxjava3.internal.subscribers.SubscriberResourceWrapper
- serialVersionUID:
- -8612022020200669122L
-
Serialized Fields
-
downstream
org.reactivestreams.Subscriber<? super T> downstream
-
upstream
AtomicReference<org.reactivestreams.Subscription> upstream
-
-
-
Package io.reactivex.rxjava3.internal.subscriptions
-
Class io.reactivex.rxjava3.internal.subscriptions.ArrayCompositeSubscription
class ArrayCompositeSubscription extends AtomicReferenceArray<org.reactivestreams.Subscription> implements Serializable- serialVersionUID:
- 2746389416410565408L
-
Class io.reactivex.rxjava3.internal.subscriptions.AsyncSubscription
class AsyncSubscription extends AtomicLong implements Serializable- serialVersionUID:
- 7028635084060361255L
-
Serialized Fields
-
actual
AtomicReference<org.reactivestreams.Subscription> actual
-
resource
AtomicReference<Disposable> resource
-
-
Class io.reactivex.rxjava3.internal.subscriptions.BasicIntQueueSubscription
class BasicIntQueueSubscription extends AtomicInteger implements Serializable- serialVersionUID:
- -6671519529404341862L
-
Class io.reactivex.rxjava3.internal.subscriptions.BasicQueueSubscription
class BasicQueueSubscription extends AtomicLong implements Serializable- serialVersionUID:
- -6671519529404341862L
-
Class io.reactivex.rxjava3.internal.subscriptions.BooleanSubscription
class BooleanSubscription extends AtomicBoolean implements Serializable- serialVersionUID:
- -8127758972444290902L
-
Class io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription
- serialVersionUID:
- -2151279923272604993L
-
Class io.reactivex.rxjava3.internal.subscriptions.ScalarSubscription
class ScalarSubscription extends AtomicInteger implements Serializable- serialVersionUID:
- -3830916580126663321L
-
Class io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter
class SubscriptionArbiter extends 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
AtomicLong missedProduced
-
missedRequested
AtomicLong missedRequested
-
missedSubscription
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
- serialVersionUID:
- 3949248817947090603L
-
Class io.reactivex.rxjava3.internal.util.VolatileSizeArrayList
class VolatileSizeArrayList extends AtomicInteger implements Serializable- serialVersionUID:
- 3972397474470203923L
-
-
Package io.reactivex.rxjava3.operators
-
Class io.reactivex.rxjava3.operators.SpscArrayQueue
- serialVersionUID:
- -1296597691183856449L
-
Serialized Fields
-
consumerIndex
AtomicLong consumerIndex
-
lookAheadStep
int lookAheadStep
-
mask
int mask
-
producerIndex
AtomicLong producerIndex
-
producerLookAhead
long producerLookAhead
-
-