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:
java.io.Serializable
,org.reactivestreams.Subscription
- Enclosing class:
- ParallelSortedJoin<T>
static final class ParallelSortedJoin.SortedJoinSubscription<T> extends java.util.concurrent.atomic.AtomicInteger implements org.reactivestreams.Subscription
-
-
Field Summary
Fields Modifier and Type Field Description (package private) boolean
cancelled
(package private) java.util.Comparator<? super T>
comparator
(package private) org.reactivestreams.Subscriber<? super T>
downstream
(package private) java.util.concurrent.atomic.AtomicReference<java.lang.Throwable>
error
(package private) int[]
indexes
(package private) java.util.List<T>[]
lists
(package private) java.util.concurrent.atomic.AtomicInteger
remaining
(package private) java.util.concurrent.atomic.AtomicLong
requested
private static long
serialVersionUID
(package private) ParallelSortedJoin.SortedJoinInnerSubscriber<T>[]
subscribers
-
Constructor Summary
Constructors Constructor Description SortedJoinSubscription(org.reactivestreams.Subscriber<? super T> actual, int n, java.util.Comparator<? super T> comparator)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel()
(package private) void
cancelAll()
(package private) void
drain()
(package private) void
innerError(java.lang.Throwable e)
(package private) void
innerNext(java.util.List<T> value, int index)
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
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
downstream
final org.reactivestreams.Subscriber<? super T> downstream
-
subscribers
final ParallelSortedJoin.SortedJoinInnerSubscriber<T>[] subscribers
-
lists
final java.util.List<T>[] lists
-
indexes
final int[] indexes
-
comparator
final java.util.Comparator<? super T> comparator
-
requested
final java.util.concurrent.atomic.AtomicLong requested
-
cancelled
volatile boolean cancelled
-
remaining
final java.util.concurrent.atomic.AtomicInteger remaining
-
error
final java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> error
-
-
Method Detail
-
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
void innerNext(java.util.List<T> value, int index)
-
innerError
void innerError(java.lang.Throwable e)
-
drain
void drain()
-
-