Class ParallelSortedJoin.SortedJoinSubscription<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.parallel.ParallelSortedJoin.SortedJoinSubscription<T>
- All Implemented Interfaces:
Serializable
,org.reactivestreams.Subscription
- Enclosing class:
ParallelSortedJoin<T>
static final class ParallelSortedJoin.SortedJoinSubscription<T>
extends AtomicInteger
implements org.reactivestreams.Subscription
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) final Comparator
<? super T> (package private) final org.reactivestreams.Subscriber
<? super T> (package private) final AtomicReference
<Throwable> (package private) final int[]
(package private) final AtomicInteger
(package private) final AtomicLong
private static final long
(package private) final ParallelSortedJoin.SortedJoinInnerSubscriber<T>[]
-
Constructor Summary
ConstructorsConstructorDescriptionSortedJoinSubscription
(org.reactivestreams.Subscriber<? super T> actual, int n, Comparator<? super T> comparator) -
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
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
downstream
-
subscribers
-
lists
-
indexes
final int[] indexes -
comparator
-
requested
-
cancelled
volatile boolean cancelled -
remaining
-
error
-
-
Constructor Details
-
SortedJoinSubscription
SortedJoinSubscription(org.reactivestreams.Subscriber<? super T> actual, int n, Comparator<? super T> comparator)
-
-
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() -
innerNext
-
innerError
-
drain
void drain()
-