Package io.reactivex.rxjava3.processors
Class AsyncProcessor.AsyncSubscription<T>
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicInteger
-
- io.reactivex.rxjava3.internal.subscriptions.BasicIntQueueSubscription<T>
-
- io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription<T>
-
- io.reactivex.rxjava3.processors.AsyncProcessor.AsyncSubscription<T>
-
- All Implemented Interfaces:
QueueFuseable<T>
,QueueSubscription<T>
,SimpleQueue<T>
,java.io.Serializable
,org.reactivestreams.Subscription
- Enclosing class:
- AsyncProcessor<T>
static final class AsyncProcessor.AsyncSubscription<@NonNull T> extends DeferredScalarSubscription<T>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) AsyncProcessor<T>
parent
private static long
serialVersionUID
-
Fields inherited from class io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription
downstream, value
-
-
Constructor Summary
Constructors Constructor Description AsyncSubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, AsyncProcessor<@NonNull T> parent)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel()
(package private) void
onComplete()
(package private) void
onError(java.lang.Throwable t)
-
Methods inherited from class io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription
clear, complete, isCancelled, isEmpty, poll, request, requestFusion, tryCancel
-
Methods inherited from class io.reactivex.rxjava3.internal.subscriptions.BasicIntQueueSubscription
offer, offer
-
Methods inherited from class java.util.concurrent.atomic.AtomicInteger
accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
parent
final AsyncProcessor<T> parent
-
-
Constructor Detail
-
AsyncSubscription
AsyncSubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, AsyncProcessor<@NonNull T> parent)
-
-
Method Detail
-
cancel
public void cancel()
- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
- Overrides:
cancel
in classDeferredScalarSubscription<T>
-
onComplete
void onComplete()
-
onError
void onError(java.lang.Throwable t)
-
-