hu.akarnokd.rxjava2.internal.subscriptions

Class SubscriptionArbiter

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

hu.akarnokd.rxjava2.internal.subscriptions.SubscriptionArbiter

All Implemented Interfaces:

java.io.Serializable, org.reactivestreams.Subscription

public final class SubscriptionArbiter
extends java.util.concurrent.atomic.AtomicInteger
implements org.reactivestreams.Subscription

Arbitrates requests and cancellation between Subscriptions.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SubscriptionArbiter()

Method Summary

Modifier and Type	Method and Description
void	cancel()
boolean	isCancelled()
void	produced(long n)
void	request(long n)
void	setSubscription(org.reactivestreams.Subscription s)

Methods inherited from class java.util.concurrent.atomic.AtomicInteger

accumulateAndGet, addAndGet, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, incrementAndGet, intValue, lazySet, longValue, set, toString, updateAndGet, weakCompareAndSet

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

Constructor Detail

SubscriptionArbiter

public SubscriptionArbiter()

Method Detail

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

produced

public void produced(long n)

setSubscription

public void setSubscription(org.reactivestreams.Subscription s)

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

isCancelled

public boolean isCancelled()