Class FlowableCreate.LatestAsyncEmitter<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicLong
io.reactivex.rxjava3.internal.operators.flowable.FlowableCreate.BaseEmitter<T>
io.reactivex.rxjava3.internal.operators.flowable.FlowableCreate.LatestAsyncEmitter<T>
- All Implemented Interfaces:
Emitter<T>
,FlowableEmitter<T>
,Serializable
,org.reactivestreams.Subscription
- Enclosing class:
FlowableCreate<T>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) Throwable
(package private) final AtomicReference
<T> private static final long
(package private) final AtomicInteger
Fields inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableCreate.BaseEmitter
downstream, serial
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) void
drain()
void
Signal a completion.void
Signal a normal value.(package private) void
(package private) void
boolean
Methods inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableCreate.BaseEmitter
cancel, completeDownstream, errorDownstream, isCancelled, onError, request, requested, serialize, setCancellable, setDisposable, toString, tryOnError
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, 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:
-
queue
-
error
Throwable error -
done
volatile boolean done -
wip
-
-
Constructor Details
-
LatestAsyncEmitter
LatestAsyncEmitter(org.reactivestreams.Subscriber<? super T> downstream)
-
-
Method Details
-
onNext
Description copied from interface:Emitter
Signal a normal value.- Parameters:
t
- the value to signal, notnull
-
signalError
- Overrides:
signalError
in classFlowableCreate.BaseEmitter<T>
-
onComplete
public void onComplete()Description copied from interface:Emitter
Signal a completion.- Specified by:
onComplete
in interfaceEmitter<T>
- Overrides:
onComplete
in classFlowableCreate.BaseEmitter<T>
-
onRequested
void onRequested()- Overrides:
onRequested
in classFlowableCreate.BaseEmitter<T>
-
onUnsubscribed
void onUnsubscribed()- Overrides:
onUnsubscribed
in classFlowableCreate.BaseEmitter<T>
-
drain
void drain()
-