Package io.reactivex.rxjava3.internal.operators.flowable

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

All Implemented Interfaces:

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

Direct Known Subclasses:

FlowableCreate.DropAsyncEmitter, FlowableCreate.ErrorAsyncEmitter

Enclosing class:

FlowableCreate<T>

abstract static class FlowableCreate.NoOverflowBaseAsyncEmitter<T>
extends FlowableCreate.BaseEmitter<T>

Field Summary

Fields

Modifier and Type	Field	Description
private static final long	serialVersionUID

Fields inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableCreate.BaseEmitter

downstream, serial

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
final void	onNext(T t)	Signal a normal value.
(package private) abstract void	onOverflow()

Methods inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableCreate.BaseEmitter

cancel, completeDownstream, errorDownstream, isCancelled, onComplete, onError, onRequested, onUnsubscribed, request, requested, serialize, setCancellable, setDisposable, signalError, 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

Methods inherited from class java.lang.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

NoOverflowBaseAsyncEmitter

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

Method Details

onNext

public final void onNext(T t)

Description copied from interface: Emitter

Signal a normal value.

Parameters:

t - the value to signal, not null

onOverflow

abstract void onOverflow()