Class ParallelJoin.JoinSubscriptionBase<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.parallel.ParallelJoin.JoinSubscriptionBase<T>
- All Implemented Interfaces:
Serializable
,org.reactivestreams.Subscription
- Direct Known Subclasses:
ParallelJoin.JoinSubscription
,ParallelJoin.JoinSubscriptionDelayError
- Enclosing class:
ParallelJoin<T>
abstract static class ParallelJoin.JoinSubscriptionBase<T>
extends AtomicInteger
implements org.reactivestreams.Subscription
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) final AtomicInteger
(package private) final org.reactivestreams.Subscriber
<? super T> (package private) final AtomicThrowable
(package private) final AtomicLong
private static final long
(package private) final ParallelJoin.JoinInnerSubscriber<T>[]
-
Constructor Summary
ConstructorsConstructorDescriptionJoinSubscriptionBase
(org.reactivestreams.Subscriber<? super T> actual, int n, int prefetch) -
Method Summary
Modifier and TypeMethodDescriptionvoid
cancel()
(package private) void
(package private) void
cleanup()
(package private) abstract void
drain()
(package private) abstract void
(package private) abstract void
(package private) abstract void
onNext
(ParallelJoin.JoinInnerSubscriber<T> inner, T value) void
request
(long n) 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
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
downstream
-
subscribers
-
errors
-
requested
-
cancelled
volatile boolean cancelled -
done
-
-
Constructor Details
-
JoinSubscriptionBase
JoinSubscriptionBase(org.reactivestreams.Subscriber<? super T> actual, int n, int prefetch)
-
-
Method Details
-
request
public void request(long n) - Specified by:
request
in interfaceorg.reactivestreams.Subscription
-
cancel
public void cancel()- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
-
cancelAll
void cancelAll() -
cleanup
void cleanup() -
onNext
-
onError
-
onComplete
abstract void onComplete() -
drain
abstract void drain()
-