hu.akarnokd.rxjava2.basetypes

Class BasicRefNonoSubscriber<R>

java.lang.Object

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

hu.akarnokd.rxjava2.basetypes.BasicRefQueueSubscription<java.lang.Void,R>

hu.akarnokd.rxjava2.basetypes.BasicRefNonoSubscriber<R>

Type Parameters:

R - the reference type

All Implemented Interfaces:

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

public abstract class BasicRefNonoSubscriber<R>
extends BasicRefQueueSubscription<java.lang.Void,R>
implements org.reactivestreams.Subscriber<java.lang.Void>

Basic subscriber that supports queue fusion, has an atomic reference and defaults onSubscribe, onNext and cancel.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected org.reactivestreams.Subscriber<? super java.lang.Void>	actual

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

ANY, ASYNC, BOUNDARY, NONE, SYNC

Constructor Summary

Constructors

Constructor and Description
BasicRefNonoSubscriber(org.reactivestreams.Subscriber<? super java.lang.Void> actual)

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	clear()
boolean	isEmpty()
void	onNext(java.lang.Void t)
void	onSubscribe(org.reactivestreams.Subscription s)
java.lang.Void	poll()
void	request(long n)
int	requestFusion(int mode)

Methods inherited from class hu.akarnokd.rxjava2.basetypes.BasicRefQueueSubscription

offer, offer

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.Subscriber

onComplete, onError

Field Detail

actual

protected final org.reactivestreams.Subscriber<? super java.lang.Void> actual

Constructor Detail

BasicRefNonoSubscriber

public BasicRefNonoSubscriber(org.reactivestreams.Subscriber<? super java.lang.Void> actual)

Method Detail

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<java.lang.Void>

onNext

public final void onNext(java.lang.Void t)

Specified by:

onNext in interface org.reactivestreams.Subscriber<java.lang.Void>

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

clear

public final void clear()

Specified by:

clear in interface io.reactivex.internal.fuseable.SimpleQueue<java.lang.Void>

Overrides:

clear in class BasicRefQueueSubscription<java.lang.Void,R>

isEmpty

public final boolean isEmpty()

Specified by:

isEmpty in interface io.reactivex.internal.fuseable.SimpleQueue<java.lang.Void>

Overrides:

isEmpty in class BasicRefQueueSubscription<java.lang.Void,R>

poll

public final java.lang.Void poll()
                          throws java.lang.Exception

Specified by:

poll in interface io.reactivex.internal.fuseable.SimpleQueue<java.lang.Void>

Overrides:

poll in class BasicRefQueueSubscription<java.lang.Void,R>

Throws:

java.lang.Exception

request

public final void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

Overrides:

request in class BasicRefQueueSubscription<java.lang.Void,R>

requestFusion

public final int requestFusion(int mode)

Specified by:

requestFusion in interface io.reactivex.internal.fuseable.QueueFuseable<java.lang.Void>

Overrides:

requestFusion in class BasicRefQueueSubscription<java.lang.Void,R>