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:
java.io.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
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 NoneAsyncEmitter(Subscriber<? super T> actual)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onNext(T t)
Provides the Observer with a new item to observe.-
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
-
NoneAsyncEmitter
public NoneAsyncEmitter(Subscriber<? super T> actual)
-
-
Method Detail
-
onNext
public 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
-
-