Class ParallelRunOn.BaseRunOnSubscriber<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.parallel.ParallelRunOn.BaseRunOnSubscriber<T>
- All Implemented Interfaces:
FlowableSubscriber<T>
,Serializable
,Runnable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Direct Known Subclasses:
ParallelRunOn.RunOnConditionalSubscriber
,ParallelRunOn.RunOnSubscriber
- Enclosing class:
ParallelRunOn<T>
abstract static class ParallelRunOn.BaseRunOnSubscriber<T>
extends AtomicInteger
implements FlowableSubscriber<T>, org.reactivestreams.Subscription, Runnable
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) int
(package private) boolean
(package private) Throwable
(package private) final int
(package private) final int
(package private) final SpscArrayQueue
<T> (package private) final AtomicLong
private static final long
(package private) org.reactivestreams.Subscription
(package private) final Scheduler.Worker
-
Constructor Summary
ConstructorsConstructorDescriptionBaseRunOnSubscriber
(int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker) -
Method Summary
Methods inherited from class java.util.concurrent.atomic.AtomicInteger
accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
Methods inherited from class java.lang.Number
byteValue, shortValue
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface io.reactivex.rxjava3.core.FlowableSubscriber
onSubscribe
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
prefetch
final int prefetch -
limit
final int limit -
queue
-
worker
-
upstream
org.reactivestreams.Subscription upstream -
done
volatile boolean done -
error
Throwable error -
requested
-
cancelled
volatile boolean cancelled -
consumed
int consumed
-
-
Constructor Details
-
BaseRunOnSubscriber
BaseRunOnSubscriber(int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker)
-
-
Method Details
-
onNext
- Specified by:
onNext
in interfaceorg.reactivestreams.Subscriber<T>
-
onError
- Specified by:
onError
in interfaceorg.reactivestreams.Subscriber<T>
-
onComplete
public final void onComplete()- Specified by:
onComplete
in interfaceorg.reactivestreams.Subscriber<T>
-
request
public final void request(long n) - Specified by:
request
in interfaceorg.reactivestreams.Subscription
-
cancel
public final void cancel()- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
-
schedule
final void schedule()
-