Package io.reactivex.rxjava3.internal.operators.flowable

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:

java.io.Serializable, org.reactivestreams.Subscription

Enclosing class:

FlowableZip<T,R>

static final class FlowableZip.ZipCoordinator<T,R>
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.lang.Object[]	current
(package private) boolean	delayErrors
(package private) org.reactivestreams.Subscriber<? super R>	downstream
(package private) AtomicThrowable	errors
(package private) java.util.concurrent.atomic.AtomicLong	requested
private static long	serialVersionUID
(package private) FlowableZip.ZipSubscriber<T,R>[]	subscribers
(package private) Function<? super java.lang.Object[],? extends R>	zipper

Constructor Summary

Constructors

Constructor	Description
ZipCoordinator(org.reactivestreams.Subscriber<? super R> actual, Function<? super java.lang.Object[],? extends R> zipper, int n, int prefetch, boolean delayErrors)

Method Summary

Modifier and Type	Method	Description
void	cancel()
(package private) void	cancelAll()
(package private) void	drain()
(package private) void	error(FlowableZip.ZipSubscriber<T,R> inner, java.lang.Throwable e)
void	request(long n)
(package private) void	subscribe(org.reactivestreams.Publisher<? extends T>[] sources, int 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

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

downstream

final org.reactivestreams.Subscriber<? super R> downstream

subscribers

final FlowableZip.ZipSubscriber<T,R>[] subscribers

zipper

final Function<? super java.lang.Object[],? extends R> zipper

requested

final java.util.concurrent.atomic.AtomicLong requested

errors

final AtomicThrowable errors

delayErrors

final boolean delayErrors

cancelled

volatile boolean cancelled

current

final java.lang.Object[] current

Constructor Detail

ZipCoordinator

ZipCoordinator(org.reactivestreams.Subscriber<? super R> actual,
               Function<? super java.lang.Object[],? extends R> zipper,
               int n,
               int prefetch,
               boolean delayErrors)

Method Detail

subscribe

void subscribe(org.reactivestreams.Publisher<? extends T>[] sources,
               int n)

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

error

void error(FlowableZip.ZipSubscriber<T,R> inner,
           java.lang.Throwable e)

cancelAll

void cancelAll()

drain

void drain()