Class FlowableMaterialize.MaterializeSubscriber<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicLong
io.reactivex.rxjava3.internal.subscribers.SinglePostCompleteSubscriber<T,Notification<T>>
io.reactivex.rxjava3.internal.operators.flowable.FlowableMaterialize.MaterializeSubscriber<T>
- All Implemented Interfaces:
FlowableSubscriber<T>
,Serializable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Enclosing class:
FlowableMaterialize<T>
static final class FlowableMaterialize.MaterializeSubscriber<T>
extends SinglePostCompleteSubscriber<T,Notification<T>>
-
Field Summary
FieldsFields inherited from class io.reactivex.rxjava3.internal.subscribers.SinglePostCompleteSubscriber
downstream, produced, upstream, value
-
Constructor Summary
ConstructorsConstructorDescriptionMaterializeSubscriber
(org.reactivestreams.Subscriber<? super Notification<T>> downstream) -
Method Summary
Modifier and TypeMethodDescriptionvoid
protected void
onDrop
(Notification<T> n) Called in case of multiple calls to complete.void
void
Methods inherited from class io.reactivex.rxjava3.internal.subscribers.SinglePostCompleteSubscriber
cancel, complete, onSubscribe, request
Methods inherited from class java.util.concurrent.atomic.AtomicLong
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
Methods inherited from class java.lang.Number
byteValue, shortValue
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
-
Constructor Details
-
MaterializeSubscriber
MaterializeSubscriber(org.reactivestreams.Subscriber<? super Notification<T>> downstream)
-
-
Method Details
-
onNext
-
onError
-
onComplete
public void onComplete() -
onDrop
Description copied from class:SinglePostCompleteSubscriber
Called in case of multiple calls to complete.- Overrides:
onDrop
in classSinglePostCompleteSubscriber<T,
Notification<T>> - Parameters:
n
- the value dropped
-