public abstract class BasicEmptyQueueSubscription
extends java.lang.Object
implements io.reactivex.internal.fuseable.QueueSubscription<java.lang.Void>
| Constructor and Description |
|---|
BasicEmptyQueueSubscription() |
| 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) |
public final boolean offer(java.lang.Void e)
offer in interface io.reactivex.internal.fuseable.SimpleQueue<java.lang.Void>public final boolean offer(java.lang.Void v1,
java.lang.Void v2)
offer in interface io.reactivex.internal.fuseable.SimpleQueue<java.lang.Void>public final void clear()
clear in interface io.reactivex.internal.fuseable.SimpleQueue<java.lang.Void>public final boolean isEmpty()
isEmpty in interface io.reactivex.internal.fuseable.SimpleQueue<java.lang.Void>public final java.lang.Void poll()
throws java.lang.Exception
poll in interface io.reactivex.internal.fuseable.SimpleQueue<java.lang.Void>java.lang.Exceptionpublic final void request(long n)
request in interface org.reactivestreams.Subscriptionpublic final int requestFusion(int mode)
requestFusion in interface io.reactivex.internal.fuseable.QueueFuseable<java.lang.Void>