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

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
protected boolean	unbounded

Constructor Summary

Constructors

Constructor	Description
SubscriptionArbiter(boolean cancelOnReplace)

Method Summary

Modifier and Type	Method	Description
void	cancel()
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

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

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