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>

static final class FlowableCreate.LatestAsyncEmitter<T>
extends FlowableCreate.BaseEmitter<T>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	done
(package private) Throwable	error
(package private) final AtomicReference<T>	queue
private static final long	serialVersionUID
(package private) final AtomicInteger	wip

Fields inherited from class FlowableCreate.BaseEmitter

downstream, serial

Constructor Summary

Constructors

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

Method Summary

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(Throwable e)

Methods inherited from class FlowableCreate.BaseEmitter

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

queue

final AtomicReference<T> queue

error

Throwable error

done

volatile boolean done

wip

final AtomicInteger wip

Constructor Details

LatestAsyncEmitter

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

Method Details

onNext

public void onNext(T t)

Description copied from interface: Emitter

Signal a normal value.

Parameters:

t - the value to signal, not null

signalError

public boolean signalError(Throwable e)

Overrides:

signalError in class FlowableCreate.BaseEmitter<T>

onComplete

public void onComplete()

Description copied from interface: Emitter

Signal a completion.

Specified by:

onComplete in interface Emitter<T>

Overrides:

onComplete in class FlowableCreate.BaseEmitter<T>

onRequested

void onRequested()

Overrides:

onRequested in class FlowableCreate.BaseEmitter<T>

onUnsubscribed

void onUnsubscribed()

Overrides:

onUnsubscribed in class FlowableCreate.BaseEmitter<T>

drain

void drain()