hu.akarnokd.rxjava2.basetypes

Class BasicNonoSubscriber

java.lang.Object

hu.akarnokd.rxjava2.basetypes.BasicEmptyQueueSubscription

hu.akarnokd.rxjava2.basetypes.BasicNonoSubscriber

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>, org.reactivestreams.Subscriber<java.lang.Object>, org.reactivestreams.Subscription

public abstract class BasicNonoSubscriber
extends BasicEmptyQueueSubscription
implements org.reactivestreams.Subscriber<java.lang.Object>

Basic subscriber that supports queue fusion and defaults onSubscribe, onNext and cancel.

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
BasicNonoSubscriber(org.reactivestreams.Subscriber<? super java.lang.Void> actual)

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	onNext(java.lang.Object t)
void	onSubscribe(org.reactivestreams.Subscription s)

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

clear, isEmpty, offer, offer, poll, request, requestFusion

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, 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

BasicNonoSubscriber

public BasicNonoSubscriber(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.Object>

onNext

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

Specified by:

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

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription