Package rx.internal.operators
Class OnSubscribeFromAsync.BaseAsyncEmitter<T>
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicLong
-
- rx.internal.operators.OnSubscribeFromAsync.BaseAsyncEmitter<T>
-
- All Implemented Interfaces:
java.io.Serializable
,AsyncEmitter<T>
,Observer<T>
,Producer
,Subscription
- Direct Known Subclasses:
OnSubscribeFromAsync.BufferAsyncEmitter
,OnSubscribeFromAsync.LatestAsyncEmitter
,OnSubscribeFromAsync.NoneAsyncEmitter
,OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter
- Enclosing class:
- OnSubscribeFromAsync<T>
abstract static class OnSubscribeFromAsync.BaseAsyncEmitter<T> extends java.util.concurrent.atomic.AtomicLong implements AsyncEmitter<T>, Producer, Subscription
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface rx.AsyncEmitter
AsyncEmitter.BackpressureMode, AsyncEmitter.Cancellable
-
-
Field Summary
Fields Modifier and Type Field Description (package private) Subscriber<? super T>
actual
(package private) SerialSubscription
serial
private static long
serialVersionUID
-
Constructor Summary
Constructors Constructor Description BaseAsyncEmitter(Subscriber<? super T> actual)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
isUnsubscribed()
Indicates whether thisSubscription
is currently unsubscribed.void
onCompleted()
Notifies the Observer that theObservable
has finished sending push-based notifications.void
onError(java.lang.Throwable e)
Notifies the Observer that theObservable
has experienced an error condition.(package private) void
onRequested()
(package private) void
onUnsubscribed()
void
request(long n)
Request a certain maximum number of items from this Producer.long
requested()
The current outstanding request amount.void
setCancellation(AsyncEmitter.Cancellable c)
Sets a Cancellable on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.void
setSubscription(Subscription s)
Sets a Subscription on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.void
unsubscribe()
Stops the receipt of notifications on theSubscriber
that was registered when this Subscription was received.-
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
-
actual
final Subscriber<? super T> actual
-
serial
final SerialSubscription serial
-
-
Constructor Detail
-
BaseAsyncEmitter
public BaseAsyncEmitter(Subscriber<? super T> actual)
-
-
Method Detail
-
onCompleted
public void onCompleted()
Description copied from interface:Observer
Notifies the Observer that theObservable
has finished sending push-based notifications.The
Observable
will not call this method if it callsObserver.onError(java.lang.Throwable)
.- Specified by:
onCompleted
in interfaceObserver<T>
-
onError
public void onError(java.lang.Throwable e)
Description copied from interface:Observer
Notifies the Observer that theObservable
has experienced an error condition.If the
Observable
calls this method, it will not thereafter callObserver.onNext(T)
orObserver.onCompleted()
.
-
unsubscribe
public final void unsubscribe()
Description copied from interface:Subscription
Stops the receipt of notifications on theSubscriber
that was registered when this Subscription was received.This allows unregistering an
Subscriber
before it has finished receiving all events (i.e. before onCompleted is called).- Specified by:
unsubscribe
in interfaceSubscription
-
onUnsubscribed
void onUnsubscribed()
-
isUnsubscribed
public final boolean isUnsubscribed()
Description copied from interface:Subscription
Indicates whether thisSubscription
is currently unsubscribed.- Specified by:
isUnsubscribed
in interfaceSubscription
- Returns:
true
if thisSubscription
is currently unsubscribed,false
otherwise
-
request
public final void request(long n)
Description copied from interface:Producer
Request a certain maximum number of items from this Producer. This is a way of requesting backpressure. To disable backpressure, passLong.MAX_VALUE
to this method.Requests are additive but if a sequence of requests totals more than
Long.MAX_VALUE
thenLong.MAX_VALUE
requests will be actioned and the extras may be ignored. Arriving atLong.MAX_VALUE
by addition of requests cannot be assumed to disable backpressure. For example, the code below may result inLong.MAX_VALUE
requests being actioned only.request(100); request(Long.MAX_VALUE-1);
-
onRequested
void onRequested()
-
setSubscription
public final void setSubscription(Subscription s)
Description copied from interface:AsyncEmitter
Sets a Subscription on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.- Specified by:
setSubscription
in interfaceAsyncEmitter<T>
- Parameters:
s
- the subscription, null is allowed
-
setCancellation
public final void setCancellation(AsyncEmitter.Cancellable c)
Description copied from interface:AsyncEmitter
Sets a Cancellable on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.- Specified by:
setCancellation
in interfaceAsyncEmitter<T>
- Parameters:
c
- the cancellable resource, null is allowed
-
requested
public final long requested()
Description copied from interface:AsyncEmitter
The current outstanding request amount.This method it threadsafe.
- Specified by:
requested
in interfaceAsyncEmitter<T>
- Returns:
- the current outstanding request amount
-
-