hu.akarnokd.rxjava2.internal.subscriptions

Class ScalarAsyncSubscription<T>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

hu.akarnokd.rxjava2.internal.subscriptions.ScalarAsyncSubscription<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

java.io.Serializable, org.reactivestreams.Subscription

public final class ScalarAsyncSubscription<T>
extends java.util.concurrent.atomic.AtomicInteger
implements org.reactivestreams.Subscription

A Subscription that coordinates the emission of a single value set asynchronously.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ScalarAsyncSubscription(org.reactivestreams.Subscriber<? super T> subscriber)

Method Summary

Modifier and Type	Method and Description
void	cancel()
boolean	isComplete()
void	request(long n)
void	setValue(T v)

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

ScalarAsyncSubscription

public ScalarAsyncSubscription(org.reactivestreams.Subscriber<? super T> subscriber)

Method Detail

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

setValue

public void setValue(T v)

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

isComplete

public boolean isComplete()