hu.akarnokd.rxjava2.basetypes

Class BasicRefQueueSubscription<T,R>

java.lang.Object

java.util.concurrent.atomic.AtomicReference<R>

hu.akarnokd.rxjava2.basetypes.BasicRefQueueSubscription<T,R>

Type Parameters:

T - the value type

R - the reference type

All Implemented Interfaces:

io.reactivex.internal.fuseable.QueueFuseable<T>, io.reactivex.internal.fuseable.QueueSubscription<T>, io.reactivex.internal.fuseable.SimpleQueue<T>, java.io.Serializable, org.reactivestreams.Subscription

Direct Known Subclasses:

BasicRefNonoSubscriber

public abstract class BasicRefQueueSubscription<T,R>
extends java.util.concurrent.atomic.AtomicReference<R>
implements io.reactivex.internal.fuseable.QueueSubscription<T>

Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).

See Also:

Serialized Form

Field Summary

Fields inherited from interface io.reactivex.internal.fuseable.QueueFuseable

ANY, ASYNC, BOUNDARY, NONE, SYNC

Constructor Summary

Constructors

Constructor and Description
BasicRefQueueSubscription()

Method Summary

Modifier and Type	Method and Description
void	clear()
boolean	isEmpty()
boolean	offer(T e)
boolean	offer(T v1, T v2)
T	poll()
void	request(long n)
int	requestFusion(int mode)

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

accumulateAndGet, compareAndSet, get, getAndAccumulate, getAndSet, getAndUpdate, lazySet, set, toString, updateAndGet, weakCompareAndSet

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.reactivestreams.Subscription

cancel

Constructor Detail

BasicRefQueueSubscription

public BasicRefQueueSubscription()

Method Detail

offer

public final boolean offer(T e)

Specified by:

offer in interface io.reactivex.internal.fuseable.SimpleQueue<T>

offer

public final boolean offer(T v1,
                           T v2)

Specified by:

offer in interface io.reactivex.internal.fuseable.SimpleQueue<T>

requestFusion

public int requestFusion(int mode)

Specified by:

requestFusion in interface io.reactivex.internal.fuseable.QueueFuseable<T>

poll

public T poll()
       throws java.lang.Exception

Specified by:

poll in interface io.reactivex.internal.fuseable.SimpleQueue<T>

Throws:

java.lang.Exception

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface io.reactivex.internal.fuseable.SimpleQueue<T>

clear

public void clear()

Specified by:

clear in interface io.reactivex.internal.fuseable.SimpleQueue<T>

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription