hu.akarnokd.rxjava2.internal.subscriptions

Class ScalarSubscription<T>

java.lang.Object

java.util.concurrent.atomic.AtomicBoolean

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

Type Parameters:

T - the value type

All Implemented Interfaces:

java.io.Serializable, org.reactivestreams.Subscription

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

A Subscription that holds a constant value and emits it only when requested.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ScalarSubscription(org.reactivestreams.Subscriber<? super T> subscriber, T value)

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	request(long n)

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

compareAndSet, get, getAndSet, lazySet, set, toString, weakCompareAndSet

Methods inherited from class java.lang.Object

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

Constructor Detail

ScalarSubscription

public ScalarSubscription(org.reactivestreams.Subscriber<? super T> subscriber,
                          T value)

Method Detail

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription