Class SubscriptionArbiter

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter

All Implemented Interfaces:

Serializable, org.reactivestreams.Subscription

Direct Known Subclasses:

FlowableConcatArray.ConcatArraySubscriber, FlowableConcatMap.ConcatMapInner, FlowableOnErrorNext.OnErrorNextSubscriber, FlowableRepeatWhen.WhenSourceSubscriber, FlowableTimeout.TimeoutFallbackSubscriber, FlowableTimeoutTimed.TimeoutFallbackSubscriber

public class SubscriptionArbiter
extends AtomicInteger
implements org.reactivestreams.Subscription

Arbitrates requests and cancellation between Subscriptions.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
(package private) org.reactivestreams.Subscription	actual	The current subscription which may null if no Subscriptions have been set.
(package private) boolean	cancelled
(package private) final boolean	cancelOnReplace
(package private) final AtomicLong	missedProduced
(package private) final AtomicLong	missedRequested
(package private) final AtomicReference<org.reactivestreams.Subscription>	missedSubscription
(package private) long	requested	The current outstanding request amount.
private static final long	serialVersionUID
protected boolean	unbounded

Constructor Summary

Constructors

Constructor	Description
SubscriptionArbiter(boolean cancelOnReplace)

Method Summary

Modifier and Type	Method	Description
void	cancel()
(package private) final void	drain()
(package private) final void	drainLoop()
final boolean	isCancelled()	Returns true if the arbiter has been cancelled.
final boolean	isUnbounded()	Returns true if the arbiter runs in unbounded mode.
final void	produced(long n)
final void	request(long n)
final void	setSubscription(org.reactivestreams.Subscription s)	Atomically sets a new subscription.

Methods inherited from class 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 Number

byteValue, shortValue

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

actual

org.reactivestreams.Subscription actual

The current subscription which may null if no Subscriptions have been set.

requested

long requested

The current outstanding request amount.

missedSubscription

final AtomicReference<org.reactivestreams.Subscription> missedSubscription

missedRequested

final AtomicLong missedRequested

missedProduced

final AtomicLong missedProduced

cancelOnReplace

final boolean cancelOnReplace

cancelled

volatile boolean cancelled

unbounded

protected boolean unbounded

Constructor Details

SubscriptionArbiter

public SubscriptionArbiter(boolean cancelOnReplace)

Method Details

setSubscription

public final void setSubscription(org.reactivestreams.Subscription s)

Atomically sets a new subscription.

Parameters:

s - the subscription to set, not null (verified)

request

public final void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

produced

public final void produced(long n)

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

drain

final void drain()

drainLoop

final void drainLoop()

isUnbounded

public final boolean isUnbounded()

Returns true if the arbiter runs in unbounded mode.

Returns:

true if the arbiter runs in unbounded mode

isCancelled

public final boolean isCancelled()

Returns true if the arbiter has been cancelled.

Returns:

true if the arbiter has been cancelled