Package rx.internal.operators
Class OnSubscribeFromAsync.ErrorAsyncEmitter<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicLong
rx.internal.operators.OnSubscribeFromAsync.BaseAsyncEmitter<T>
rx.internal.operators.OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter<T>
rx.internal.operators.OnSubscribeFromAsync.ErrorAsyncEmitter<T>
- All Implemented Interfaces:
Serializable
,AsyncEmitter<T>
,Observer<T>
,Producer
,Subscription
- Enclosing class:
OnSubscribeFromAsync<T>
static final class OnSubscribeFromAsync.ErrorAsyncEmitter<T>
extends OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter<T>
-
Nested Class Summary
Nested classes/interfaces inherited from interface rx.AsyncEmitter
AsyncEmitter.BackpressureMode, AsyncEmitter.Cancellable
-
Field Summary
FieldsFields inherited from class rx.internal.operators.OnSubscribeFromAsync.BaseAsyncEmitter
actual, serial
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class rx.internal.operators.OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter
onNext
Methods inherited from class rx.internal.operators.OnSubscribeFromAsync.BaseAsyncEmitter
isUnsubscribed, onCompleted, onError, onRequested, onUnsubscribed, request, requested, setCancellation, setSubscription, unsubscribe
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, toString, 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:
-
-
Constructor Details
-
ErrorAsyncEmitter
-
-
Method Details
-
onOverflow
void onOverflow()- Specified by:
onOverflow
in classOnSubscribeFromAsync.NoOverflowBaseAsyncEmitter<T>
-