Class FlowableCreate.ErrorAsyncEmitter<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.NoOverflowBaseAsyncEmitter<T>

io.reactivex.rxjava3.internal.operators.flowable.FlowableCreate.ErrorAsyncEmitter<T>

All Implemented Interfaces:

Emitter<T>, FlowableEmitter<T>, Serializable, org.reactivestreams.Subscription

Enclosing class:

FlowableCreate<T>

static final class FlowableCreate.ErrorAsyncEmitter<T>
extends FlowableCreate.NoOverflowBaseAsyncEmitter<T>

Field Summary

Fields

Modifier and Type	Field	Description
private static final long	serialVersionUID

Fields inherited from class FlowableCreate.BaseEmitter

downstream, serial

Constructor Summary

Constructors

Constructor	Description
ErrorAsyncEmitter(org.reactivestreams.Subscriber<? super T> downstream)

Method Summary

Modifier and Type	Method	Description
(package private) void	onOverflow()

Methods inherited from class FlowableCreate.NoOverflowBaseAsyncEmitter

onNext

Methods inherited from class FlowableCreate.BaseEmitter

cancel, completeDownstream, errorDownstream, isCancelled, onComplete, onError, onRequested, onUnsubscribed, request, requested, serialize, setCancellable, setDisposable, signalError, toString, tryOnError

Methods inherited from class 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 Number

byteValue, shortValue

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

Constructor Details

ErrorAsyncEmitter

ErrorAsyncEmitter(org.reactivestreams.Subscriber<? super T> downstream)

Method Details

onOverflow

void onOverflow()

Specified by:

onOverflow in class FlowableCreate.NoOverflowBaseAsyncEmitter<T>