Package rx.internal.operators
Class OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter<T>
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicLong
-
- rx.internal.operators.OnSubscribeFromAsync.BaseAsyncEmitter<T>
-
- rx.internal.operators.OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter<T>
-
- All Implemented Interfaces:
java.io.Serializable
,AsyncEmitter<T>
,Observer<T>
,Producer
,Subscription
- Direct Known Subclasses:
OnSubscribeFromAsync.DropAsyncEmitter
,OnSubscribeFromAsync.ErrorAsyncEmitter
- Enclosing class:
- OnSubscribeFromAsync<T>
abstract static class OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter<T> extends OnSubscribeFromAsync.BaseAsyncEmitter<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 NoOverflowBaseAsyncEmitter(Subscriber<? super T> actual)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
onNext(T t)
Provides the Observer with a new item to observe.(package private) abstract void
onOverflow()
-
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
-
NoOverflowBaseAsyncEmitter
public NoOverflowBaseAsyncEmitter(Subscriber<? super T> actual)
-
-
Method Detail
-
onNext
public final void onNext(T t)
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
-
onOverflow
abstract void onOverflow()
-
-