Package rx.internal.operators
Class OnSubscribeFromAsync.NoneAsyncEmitter<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicLong
rx.internal.operators.OnSubscribeFromAsync.BaseAsyncEmitter<T>
rx.internal.operators.OnSubscribeFromAsync.NoneAsyncEmitter<T>
- All Implemented Interfaces:
Serializable
,AsyncEmitter<T>
,Observer<T>
,Producer
,Subscription
- Enclosing class:
OnSubscribeFromAsync<T>
static final class OnSubscribeFromAsync.NoneAsyncEmitter<T>
extends OnSubscribeFromAsync.BaseAsyncEmitter<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.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
-
NoneAsyncEmitter
-
-
Method Details
-
onNext
Description copied from interface:Observer
Provides the Observer with a new item to observe.The
Observable
may call this method 0 or more times.The
Observable
will not call this method again after it calls eitherObserver.onCompleted()
orObserver.onError(java.lang.Throwable)
.- Parameters:
t
- the item emitted by the Observable
-