Class FlowableCreate.BufferAsyncEmitter<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.BufferAsyncEmitter<T>
-
- All Implemented Interfaces:
Emitter<T>
,FlowableEmitter<T>
,java.io.Serializable
,org.reactivestreams.Subscription
- Enclosing class:
- FlowableCreate<T>
static final class FlowableCreate.BufferAsyncEmitter<T> extends FlowableCreate.BaseEmitter<T>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) boolean
done
(package private) java.lang.Throwable
error
(package private) SpscLinkedArrayQueue<T>
queue
private static long
serialVersionUID
(package private) java.util.concurrent.atomic.AtomicInteger
wip
-
Fields inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableCreate.BaseEmitter
downstream, serial
-
-
Constructor Summary
Constructors Constructor Description BufferAsyncEmitter(org.reactivestreams.Subscriber<? super T> actual, int capacityHint)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
drain()
void
onComplete()
Signal a completion.void
onNext(T t)
Signal a normal value.(package private) void
onRequested()
(package private) void
onUnsubscribed()
boolean
signalError(java.lang.Throwable e)
-
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
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
queue
final SpscLinkedArrayQueue<T> queue
-
error
java.lang.Throwable error
-
done
volatile boolean done
-
wip
final java.util.concurrent.atomic.AtomicInteger wip
-
-
Constructor Detail
-
BufferAsyncEmitter
BufferAsyncEmitter(org.reactivestreams.Subscriber<? super T> actual, int capacityHint)
-
-
Method Detail
-
onNext
public void onNext(T t)
Description copied from interface:Emitter
Signal a normal value.- Parameters:
t
- the value to signal, notnull
-
signalError
public boolean signalError(java.lang.Throwable e)
- 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()
-
-