Package rx.internal.operators

Class OperatorOnBackpressureBuffer.BufferSubscriber<T>

java.lang.Object

rx.Subscriber<T>

rx.internal.operators.OperatorOnBackpressureBuffer.BufferSubscriber<T>

All Implemented Interfaces:

BackpressureDrainManager.BackpressureQueueCallback, Observer<T>, Subscription

Enclosing class:

OperatorOnBackpressureBuffer<T>

static final class OperatorOnBackpressureBuffer.BufferSubscriber<T>
extends Subscriber<T>
implements BackpressureDrainManager.BackpressureQueueCallback

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicLong	capacity
private final Subscriber<? super T>	child
private final BackpressureDrainManager	manager
private final NotificationLite<T>	on
private final Action0	onOverflow
private final BackpressureOverflow.Strategy	overflowStrategy
private final ConcurrentLinkedQueue<Object>	queue
private final AtomicBoolean	saturated

Constructor Summary

Constructors

Constructor	Description
BufferSubscriber(Subscriber<? super T> child, Long capacity, Action0 onOverflow, BackpressureOverflow.Strategy overflowStrategy)

Method Summary

Modifier and Type	Method	Description
boolean	accept(Object value)	Override this method to deliver an element to downstream.
private boolean	assertCapacity()
void	complete(Throwable exception)	Override this method to deliver a normal or exceptional terminal event.
protected Producer	manager()
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.
void	onStart()	This method is invoked when the Subscriber and Observable have been connected but the Observable has not yet begun to emit items or send notifications to the Subscriber.
Object	peek()	Override this method to peek for the next element, null meaning no next element available now.
Object	poll()	Override this method to poll (consume) the next element, null meaning no next element available now.

Methods inherited from class rx.Subscriber

add, isUnsubscribed, request, setProducer, unsubscribe

Methods inherited from class java.lang.Object

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

Field Details

queue

private final ConcurrentLinkedQueue<Object> queue

capacity

private final AtomicLong capacity

child

private final Subscriber<? super T> child

saturated

private final AtomicBoolean saturated

manager

private final BackpressureDrainManager manager

on

private final NotificationLite<T> on

onOverflow

private final Action0 onOverflow

overflowStrategy

private final BackpressureOverflow.Strategy overflowStrategy

Constructor Details

BufferSubscriber

public BufferSubscriber(Subscriber<? super T> child,
 Long capacity,
 Action0 onOverflow,
 BackpressureOverflow.Strategy overflowStrategy)

Method Details

onStart

public void onStart()

Description copied from class: Subscriber

This method is invoked when the Subscriber and Observable have been connected but the Observable has not yet begun to emit items or send notifications to the Subscriber. Override this method to add any useful initialization to your subscription, for instance to initiate backpressure.

Overrides:

onStart in class Subscriber<T>

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>

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>

Parameters:

e - the exception encountered by the Observable

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).

Specified by:

onNext in interface Observer<T>

Parameters:

t - the item emitted by the Observable

accept

public boolean accept(Object value)

Description copied from interface: BackpressureDrainManager.BackpressureQueueCallback

Override this method to deliver an element to downstream. The logic ensures that this happens only in the right conditions.

Specified by:

accept in interface BackpressureDrainManager.BackpressureQueueCallback

Parameters:

value - the value to deliver, not null

Returns:

true indicates that one should terminate the emission loop unconditionally and not deliver any further elements or terminal events.

complete

public void complete(Throwable exception)

Description copied from interface: BackpressureDrainManager.BackpressureQueueCallback

Override this method to deliver a normal or exceptional terminal event.

Specified by:

complete in interface BackpressureDrainManager.BackpressureQueueCallback

Parameters:

exception - if not null, contains the terminal exception

peek

public Object peek()

Description copied from interface: BackpressureDrainManager.BackpressureQueueCallback

Override this method to peek for the next element, null meaning no next element available now.

It will be called plain and while holding this object's monitor.

Specified by:

peek in interface BackpressureDrainManager.BackpressureQueueCallback

Returns:

the next element or null if no next element available

poll

public Object poll()

Description copied from interface: BackpressureDrainManager.BackpressureQueueCallback

Override this method to poll (consume) the next element, null meaning no next element available now.

Specified by:

poll in interface BackpressureDrainManager.BackpressureQueueCallback

Returns:

the next element or null if no next element available

assertCapacity

private boolean assertCapacity()

manager

protected Producer manager()