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:
java.io.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
Fields Modifier and Type Field Description private static long
serialVersionUID
-
Fields inherited from class rx.internal.operators.OnSubscribeFromAsync.BaseAsyncEmitter
actual, serial
-
-
Constructor Summary
Constructors Constructor Description ErrorAsyncEmitter(Subscriber<? super T> actual)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
onOverflow()
-
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
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
ErrorAsyncEmitter
public ErrorAsyncEmitter(Subscriber<? super T> actual)
-
-
Method Detail
-
onOverflow
void onOverflow()
- Specified by:
onOverflow
in classOnSubscribeFromAsync.NoOverflowBaseAsyncEmitter<T>
-
-