Package rx.internal.operators

Class OnSubscribeFromAsync.BufferAsyncEmitter<T>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicLong

rx.internal.operators.OnSubscribeFromAsync.BaseAsyncEmitter<T>

rx.internal.operators.OnSubscribeFromAsync.BufferAsyncEmitter<T>

All Implemented Interfaces:

Serializable, AsyncEmitter<T>, Observer<T>, Producer, Subscription

Enclosing class:

OnSubscribeFromAsync<T>

static final class OnSubscribeFromAsync.BufferAsyncEmitter<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
(package private) boolean	done
(package private) Throwable	error
(package private) final NotificationLite<T>	nl
(package private) final Queue<Object>	queue
private static final long	serialVersionUID
(package private) final AtomicInteger	wip

Fields inherited from class rx.internal.operators.OnSubscribeFromAsync.BaseAsyncEmitter

actual, serial

Constructor Summary

Constructors

Constructor	Description
BufferAsyncEmitter(Subscriber<? super T> actual, int capacityHint)

Method Summary

Modifier and Type	Method	Description
(package private) void	drain()
void	onCompleted()	Notifies the Observer that the Observable has finished sending push-based notifications.
void	onError(Throwable e)	Notifies the Observer that the Observable has experienced an error condition.
void	onNext(T t)	Provides the Observer with a new item to observe.
(package private) void	onRequested()
(package private) void	onUnsubscribed()

Methods inherited from class rx.internal.operators.OnSubscribeFromAsync.BaseAsyncEmitter

isUnsubscribed, 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

queue

final Queue<Object> queue

error

Throwable error

done

volatile boolean done

wip

final AtomicInteger wip

nl

final NotificationLite<T> nl

Constructor Details

BufferAsyncEmitter

public BufferAsyncEmitter(Subscriber<? super T> actual,
 int capacityHint)

Method Details

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 either Observer.onCompleted() or Observer.onError(java.lang.Throwable).

Parameters:

t - the item emitted by the Observable

onError

public void onError(Throwable e)

Description copied from interface: Observer

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call Observer.onNext(T) or Observer.onCompleted().

Specified by:

onError in interface Observer<T>

Overrides:

onError in class OnSubscribeFromAsync.BaseAsyncEmitter<T>

Parameters:

e - the exception encountered by the Observable

onCompleted

public void onCompleted()

Description copied from interface: Observer

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls Observer.onError(java.lang.Throwable).

Specified by:

onCompleted in interface Observer<T>

Overrides:

onCompleted in class OnSubscribeFromAsync.BaseAsyncEmitter<T>

onRequested

void onRequested()

Overrides:

onRequested in class OnSubscribeFromAsync.BaseAsyncEmitter<T>

onUnsubscribed

void onUnsubscribed()

Overrides:

onUnsubscribed in class OnSubscribeFromAsync.BaseAsyncEmitter<T>

drain

void drain()