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:
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 AtomicLong
implements AsyncEmitter<T>, Producer, Subscription
-
Nested Class Summary
Nested classes/interfaces inherited from interface rx.AsyncEmitter
AsyncEmitter.BackpressureMode, AsyncEmitter.Cancellable
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final Subscriber
<? super T> (package private) final SerialSubscription
private static final long
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionfinal boolean
Indicates whether thisSubscription
is currently unsubscribed.void
Notifies the Observer that theObservable
has finished sending push-based notifications.void
Notifies the Observer that theObservable
has experienced an error condition.(package private) void
(package private) void
final void
request
(long n) Request a certain maximum number of items from this Producer.final long
The current outstanding request amount.final void
Sets a Cancellable on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.final void
Sets a Subscription on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.final void
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
Methods inherited from class java.lang.Number
byteValue, shortValue
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
actual
-
serial
-
-
Constructor Details
-
BaseAsyncEmitter
-
-
Method Details
-
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
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
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
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
-