Top Description Fields Constructors Methods
io.reactivex.internal.subscriptions

public abstract Class BasicIntQueueSubscription<T>

extends AtomicInteger
implements QueueSubscription<T>
Class Inheritance
All Implemented Interfaces
io.reactivex.internal.fuseable.QueueSubscription, org.reactivestreams.Subscription, io.reactivex.internal.fuseable.QueueFuseable, io.reactivex.internal.fuseable.SimpleQueue
Known Direct Subclasses
io.reactivex.internal.subscriptions.DeferredScalarSubscription, io.reactivex.processors.UnicastProcessor.UnicastQueueSubscription, io.reactivex.internal.operators.flowable.FlowableCombineLatest.CombineLatestCoordinator, io.reactivex.internal.operators.flowable.FlowableGroupBy.GroupBySubscriber, io.reactivex.internal.operators.flowable.FlowableGroupBy.State, io.reactivex.internal.operators.flowable.FlowableDoFinally.DoFinallySubscriber, io.reactivex.internal.operators.flowable.FlowableDoFinally.DoFinallyConditionalSubscriber, io.reactivex.internal.operators.flowable.FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber, io.reactivex.internal.operators.flowable.FlowableFlattenIterable.FlattenIterableSubscriber, io.reactivex.internal.operators.flowable.FlowableObserveOn.BaseObserveOnSubscriber, io.reactivex.internal.operators.flowable.FlowableOnBackpressureBuffer.BackpressureBufferSubscriber, io.reactivex.internal.operators.maybe.MaybeMergeArray.MergeMaybeObserver, io.reactivex.internal.operators.maybe.MaybeFlatMapIterableFlowable.FlatMapIterableObserver, io.reactivex.internal.operators.single.SingleFlatMapIterableFlowable.FlatMapIterableObserver
Type Parameters
<T>
the value type
Imports
java.util.concurrent.atomic.AtomicInteger, io.reactivex.internal.fuseable.QueueSubscription
Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).

Field Summary

Modifier and TypeField and Description
private static final long
serialVersionUID

Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

Constructor Summary

AccessConstructor and Description
public
BasicIntQueueSubscription()

Method Summary

Modifier and TypeMethod and Description
public final boolean
offer(T
the value to enqueue, not null
e)

Implements io.reactivex.internal.fuseable.SimpleQueue.offer.

Atomically enqueue a single.
public final boolean
offer(T
the first value to enqueue, not null
v1, T
the second value to enqueue, not null
v2)

Implements io.reactivex.internal.fuseable.SimpleQueue.offer.

Atomically enqueue two values.
Inherited from java.util.concurrent.atomic.AtomicInteger:
accumulateAndGetaddAndGetcompareAndExchangecompareAndExchangeAcquirecompareAndExchangeReleasecompareAndSetdecrementAndGetdoubleValuefloatValuegetgetAcquiregetAndAccumulategetAndAddgetAndDecrementgetAndIncrementgetAndSetgetAndUpdategetOpaquegetPlainincrementAndGetintValuelazySetlongValuesetsetOpaquesetPlainsetReleasetoStringupdateAndGetweakCompareAndSetweakCompareAndSetAcquireweakCompareAndSetPlainweakCompareAndSetReleaseweakCompareAndSetVolatile

Field Detail

serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

Constructor Detail

BasicIntQueueSubscriptionback to summary
public BasicIntQueueSubscription()

Method Detail

offerback to summary
public final boolean offer(T e)

Implements io.reactivex.internal.fuseable.SimpleQueue.offer.

Doc from io.reactivex.internal.fuseable.SimpleQueue.offer.

Atomically enqueue a single.

Parameters
e:T

the value to enqueue, not null

Returns:boolean

true if successful, false if the value was not enqueued likely due to reaching the queue capacity)

Annotations
@Override
offerback to summary
public final boolean offer(T v1, T v2)

Implements io.reactivex.internal.fuseable.SimpleQueue.offer.

Doc from io.reactivex.internal.fuseable.SimpleQueue.offer.

Atomically enqueue two values.

Parameters
v1:T

the first value to enqueue, not null

v2:T

the second value to enqueue, not null

Returns:boolean

true if successful, false if the value was not enqueued likely due to reaching the queue capacity)

Annotations
@Override