Package io.reactivex.rxjava3.internal.jdk8

Class ParallelCollector.ParallelCollectorSubscriber<T,A,R>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

io.reactivex.rxjava3.internal.subscriptions.BasicIntQueueSubscription<T>

io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription<R>

io.reactivex.rxjava3.internal.jdk8.ParallelCollector.ParallelCollectorSubscriber<T,A,R>

All Implemented Interfaces:

QueueFuseable<R>, QueueSubscription<R>, SimpleQueue<R>, java.io.Serializable, org.reactivestreams.Subscription

Enclosing class:

ParallelCollector<T,A,R>

static final class ParallelCollector.ParallelCollectorSubscriber<T,A,R>
extends DeferredScalarSubscription<R>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) java.util.concurrent.atomic.AtomicReference<ParallelCollector.SlotPair<A>>	current
(package private) AtomicThrowable	error
(package private) java.util.function.Function<A,R>	finisher
(package private) java.util.concurrent.atomic.AtomicInteger	remaining
private static long	serialVersionUID
(package private) ParallelCollector.ParallelCollectorInnerSubscriber<T,A,R>[]	subscribers

Fields inherited from class io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription

downstream, value

Fields inherited from interface io.reactivex.rxjava3.operators.QueueFuseable

ANY, ASYNC, BOUNDARY, NONE, SYNC

Constructor Summary

Constructors

Constructor	Description
ParallelCollectorSubscriber(org.reactivestreams.Subscriber<? super R> subscriber, int n, java.util.stream.Collector<T,A,R> collector)

Method Summary

Modifier and Type	Method	Description
(package private) ParallelCollector.SlotPair<A>	addValue(A value)
void	cancel()
(package private) void	innerComplete(A value, java.util.function.BinaryOperator<A> combiner)
(package private) void	innerError(java.lang.Throwable ex)

Methods inherited from class io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription

clear, complete, isCancelled, isEmpty, poll, request, requestFusion, tryCancel

Methods inherited from class io.reactivex.rxjava3.internal.subscriptions.BasicIntQueueSubscription

offer, offer

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

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

subscribers

final ParallelCollector.ParallelCollectorInnerSubscriber<T,A,R>[] subscribers

current

final java.util.concurrent.atomic.AtomicReference<ParallelCollector.SlotPair<A>> current

remaining

final java.util.concurrent.atomic.AtomicInteger remaining

error

final AtomicThrowable error

finisher

final java.util.function.Function<A,R> finisher

Constructor Detail

ParallelCollectorSubscriber

ParallelCollectorSubscriber(org.reactivestreams.Subscriber<? super R> subscriber,
                            int n,
                            java.util.stream.Collector<T,A,R> collector)

Method Detail

addValue

ParallelCollector.SlotPair<A> addValue(A value)

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

Overrides:

cancel in class DeferredScalarSubscription<R>

innerError

void innerError(java.lang.Throwable ex)

innerComplete

void innerComplete(A value,
                   java.util.function.BinaryOperator<A> combiner)