Class FlowableZip.ZipCoordinator<T,R>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.flowable.FlowableZip.ZipCoordinator<T,R>
- All Implemented Interfaces:
Serializable
,org.reactivestreams.Subscription
- Enclosing class:
FlowableZip<T,
R>
static final class FlowableZip.ZipCoordinator<T,R>
extends AtomicInteger
implements org.reactivestreams.Subscription
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) final Object[]
(package private) final boolean
(package private) final org.reactivestreams.Subscriber
<? super R> (package private) final AtomicThrowable
(package private) final AtomicLong
private static final long
(package private) final FlowableZip.ZipSubscriber<T,
R>[] -
Constructor Summary
ConstructorsConstructorDescriptionZipCoordinator
(org.reactivestreams.Subscriber<? super R> actual, Function<? super Object[], ? extends R> zipper, int n, int prefetch, boolean delayErrors) -
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
-
zipper
-
requested
-
errors
-
delayErrors
final boolean delayErrors -
cancelled
volatile boolean cancelled -
current
-
-
Constructor Details
-
ZipCoordinator
-
-
Method Details
-
subscribe
-
request
public void request(long n) - Specified by:
request
in interfaceorg.reactivestreams.Subscription
-
cancel
public void cancel()- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
-
error
-
cancelAll
void cancelAll() -
drain
void drain()
-