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>
,java.io.Serializable
,java.lang.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 java.util.concurrent.atomic.AtomicInteger implements FlowableSubscriber<T>, org.reactivestreams.Subscription, java.lang.Runnable
-
-
Field Summary
Fields Modifier and Type Field Description (package private) boolean
cancelled
(package private) int
consumed
(package private) boolean
done
(package private) java.lang.Throwable
error
(package private) int
limit
(package private) int
prefetch
(package private) SpscArrayQueue<T>
queue
(package private) java.util.concurrent.atomic.AtomicLong
requested
private static long
serialVersionUID
(package private) org.reactivestreams.Subscription
upstream
(package private) Scheduler.Worker
worker
-
Constructor Summary
Constructors Constructor Description BaseRunOnSubscriber(int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel()
void
onComplete()
void
onError(java.lang.Throwable t)
void
onNext(T t)
void
request(long n)
(package private) void
schedule()
-
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.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface io.reactivex.rxjava3.core.FlowableSubscriber
onSubscribe
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
prefetch
final int prefetch
-
limit
final int limit
-
queue
final SpscArrayQueue<T> queue
-
worker
final Scheduler.Worker worker
-
upstream
org.reactivestreams.Subscription upstream
-
done
volatile boolean done
-
error
java.lang.Throwable error
-
requested
final java.util.concurrent.atomic.AtomicLong requested
-
cancelled
volatile boolean cancelled
-
consumed
int consumed
-
-
Constructor Detail
-
BaseRunOnSubscriber
BaseRunOnSubscriber(int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker)
-
-
Method Detail
-
onNext
public final void onNext(T t)
- Specified by:
onNext
in interfaceorg.reactivestreams.Subscriber<T>
-
onError
public final void onError(java.lang.Throwable t)
- 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()
-
-