hu.akarnokd.rxjava2.basetypes

Class BasicEmptyQueueSubscription

java.lang.Object

hu.akarnokd.rxjava2.basetypes.BasicEmptyQueueSubscription

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

Direct Known Subclasses:

BasicNonoSubscriber

public abstract class BasicEmptyQueueSubscription
extends java.lang.Object
implements io.reactivex.internal.fuseable.QueueSubscription<java.lang.Void>

Base class for empty, async-fuseable intermediate operators.

Field Summary

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

ANY, ASYNC, BOUNDARY, NONE, SYNC

Constructor Summary

Constructors

Constructor and Description
BasicEmptyQueueSubscription()

Method Summary

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.reactivestreams.Subscription

cancel

Constructor Detail

BasicEmptyQueueSubscription

public BasicEmptyQueueSubscription()

Method Detail

offer

public final boolean offer(java.lang.Void e)

Specified by:

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

offer

public final boolean offer(java.lang.Void v1,
                           java.lang.Void v2)

Specified by:

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

clear

public final void clear()

Specified by:

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

isEmpty

public final boolean isEmpty()

Specified by:

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

poll

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

Specified by:

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

Throws:

java.lang.Exception

request

public final void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

requestFusion

public final int requestFusion(int mode)

Specified by:

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