Modifier and Type	Class and Description
pack-priv static class	OperatorOnBackpressureBuffer.BufferSubscriber<T>
pack-priv static class	OperatorOnBackpressureBuffer.Holder

Modifier and Type	Field and Description
private final Long	capacity
private final Action0	onOverflow
private final BackpressureOverflow.Strategy	overflowStrategy

Access	Constructor and Description
pack-priv	OperatorOnBackpressureBuffer()
public	OperatorOnBackpressureBuffer(long the max number of items to be admitted in the buffer, must be greater than 0. capacity) Construct a new instance that will handle overflows with `ON_OVERFLOW_DEFAULT`, providing the following behavior config:
public	OperatorOnBackpressureBuffer(long the max number of items to be admitted in the buffer, must be greater than 0. capacity, Action0 the `Action0` to execute when the buffer overflows, may be null. onOverflow) Construct a new instance that will handle overflows with `ON_OVERFLOW_DEFAULT`, providing the following behavior config:
public	OperatorOnBackpressureBuffer(long the max number of items to be admitted in the buffer, must be greater than 0. capacity, Action0 the `Action0` to execute when the buffer overflows, may be null. onOverflow, BackpressureOverflow.Strategy the `BackpressureOverflow.Strategy` to handle overflows, it must not be null. overflowStrategy) Construct a new instance feeding the following behavior config:

Modifier and Type	Method and Description
public Subscriber<? super T>	call(final Subscriber<? super T> child) Implements rx.functions.Func1.call.
public static <T> OperatorOnBackpressureBuffer<T>	instance()

capacity	back to summary
private final Long capacity

onOverflow	back to summary
private final Action0 onOverflow

overflowStrategy	back to summary
private final BackpressureOverflow.Strategy overflowStrategy

Constructor Detail

OperatorOnBackpressureBuffer	back to summary
pack-priv OperatorOnBackpressureBuffer()

OperatorOnBackpressureBuffer back to summary

OperatorOnBackpressureBuffer	back to summary
public OperatorOnBackpressureBuffer(long capacity) Construct a new instance that will handle overflows with `ON_OVERFLOW_DEFAULT`, providing the following behavior config: Parameters capacity:long the max number of items to be admitted in the buffer, must be greater than 0.

public OperatorOnBackpressureBuffer(long capacity)

Construct a new instance that will handle overflows with ON_OVERFLOW_DEFAULT, providing the following behavior config:

Parameters

capacity:long: the max number of items to be admitted in the buffer, must be greater than 0.

OperatorOnBackpressureBuffer back to summary

OperatorOnBackpressureBuffer	back to summary
public OperatorOnBackpressureBuffer(long capacity, Action0 onOverflow) Construct a new instance that will handle overflows with `ON_OVERFLOW_DEFAULT`, providing the following behavior config: Parameters capacity:long the max number of items to be admitted in the buffer, must be greater than 0. onOverflow:Action0 the `Action0` to execute when the buffer overflows, may be null.

public OperatorOnBackpressureBuffer(long capacity, Action0 onOverflow)

Construct a new instance that will handle overflows with ON_OVERFLOW_DEFAULT, providing the following behavior config:

Parameters

capacity:long: the max number of items to be admitted in the buffer, must be greater than 0.
onOverflow:Action0: the Action0 to execute when the buffer overflows, may be null.

OperatorOnBackpressureBuffer back to summary

OperatorOnBackpressureBuffer	back to summary
public OperatorOnBackpressureBuffer(long capacity, Action0 onOverflow, BackpressureOverflow.Strategy overflowStrategy) Construct a new instance feeding the following behavior config: Parameters capacity:long the max number of items to be admitted in the buffer, must be greater than 0. onOverflow:Action0 the `Action0` to execute when the buffer overflows, may be null. overflowStrategy:BackpressureOverflow.Strategy the `BackpressureOverflow.Strategy` to handle overflows, it must not be null.

public OperatorOnBackpressureBuffer(long capacity, Action0 onOverflow, BackpressureOverflow.Strategy overflowStrategy)

Construct a new instance feeding the following behavior config:

Parameters

capacity:long: the max number of items to be admitted in the buffer, must be greater than 0.
onOverflow:Action0: the Action0 to execute when the buffer overflows, may be null.
overflowStrategy:BackpressureOverflow.Strategy: the BackpressureOverflow.Strategy to handle overflows, it must not be null.

call	back to summary
public Subscriber<? super T> call(final Subscriber<? super T> child) Implements rx.functions.Func1.call. Annotations @Override

instance	back to summary
public static <T> OperatorOnBackpressureBuffer<T> instance() Annotations @SuppressWarnings:unchecked

rx.internal.operators back to summary

pack-priv final Class OperatorOnBackpressureBuffer.BufferSubscriber<T>

Class Inheritance

extends Subscriber<T>
implements BackpressureQueueCallback

java.lang.Object
rx.Subscriber
rx.internal.operators.OperatorOnBackpressureBuffer.BufferSubscriber

All Implemented Interfaces

rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback

Field Summary

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

Constructor Summary

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

Method Summary

Modifier and Type	Method and Description
public boolean	accept(Object the value to deliver, not null value) Implements rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.accept. Override this method to deliver an element to downstream.
private boolean	assertCapacity()
public void	complete(Throwable if not null, contains the terminal exception exception) Implements rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.complete. Override this method to deliver a normal or exceptional terminal event.
protected Producer	manager()
public void	onCompleted() Implements rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications.
public void	onError(Throwable the exception encountered by the Observable e) Implements rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public void	onNext(T the item emitted by the Observable t) Implements rx.Observer.onNext. Provides the Observer with a new item to observe.
public void	onStart() Overrides rx.Subscriber.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.
public Object	peek() Implements rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.peek. Override this method to peek for the next element, null meaning no next element available now.
public Object	poll() Implements rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.poll. Override this method to poll (consume) the next element, null meaning no next element available now.

Inherited from rx.Subscriber:: add isUnsubscribed request setProducer unsubscribe

Field Detail

capacity	back to summary
private final AtomicLong capacity

child	back to summary
private final Subscriber<? super T> child

manager	back to summary
private final BackpressureDrainManager manager

onOverflow	back to summary
private final Action0 onOverflow

overflowStrategy	back to summary
private final BackpressureOverflow.Strategy overflowStrategy

queue	back to summary
private final ConcurrentLinkedQueue<Object> queue

saturated	back to summary
private final AtomicBoolean saturated

Constructor Detail

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

Method Detail

accept	back to summary
public boolean accept(Object value) Implements rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.accept. Doc from rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.accept. Override this method to deliver an element to downstream. The logic ensures that this happens only in the right conditions. Parameters value:Object the value to deliver, not null Returns:boolean true indicates that one should terminate the emission loop unconditionally and not deliver any further elements or terminal events. Annotations @Override

back to summary

public boolean accept(Object value)

Implements rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.accept.

Doc from rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.accept.

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

Parameters

value:Object: the value to deliver, not null

Returns:boolean

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

Annotations

@Override

assertCapacity	back to summary
private boolean assertCapacity()

complete	back to summary
public void complete(Throwable exception) Implements rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.complete. Doc from rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.complete. Override this method to deliver a normal or exceptional terminal event. Parameters exception:Throwable if not null, contains the terminal exception Annotations @Override

complete

back to summary

public void complete(Throwable exception)

Implements rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.complete.

Doc from rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.complete.

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

Parameters

exception:Throwable: if not null, contains the terminal exception

Annotations

@Override

manager	back to summary
protected Producer manager()

onCompleted back to summary

onCompleted	back to summary
public void onCompleted() Implements rx.Observer.onCompleted. Doc from rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications. The `Observable` will not call this method if it calls `onError`. Annotations @Override

public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

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

The Observable will not call this method if it calls onError.

Annotations

@Override

onError back to summary

onError	back to summary
public void onError(Throwable e) Implements rx.Observer.onError. Doc from rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition. If the `Observable` calls this method, it will not thereafter call `onNext` or `onCompleted`. Parameters e:Throwable the exception encountered by the Observable Annotations @Override

public void onError(Throwable e)

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

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

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

Parameters

e:Throwable: the exception encountered by the Observable

Annotations

@Override

onNext back to summary

onNext	back to summary
public void onNext(T t) Implements rx.Observer.onNext. Doc from rx.Observer.onNext. 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 `onCompleted` or `onError`. Parameters t:T the item emitted by the Observable Annotations @Override

public void onNext(T t)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

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 onCompleted or onError.

Parameters

t:T: the item emitted by the Observable

Annotations

@Override

onStart	back to summary
public void onStart() Overrides rx.Subscriber.onStart. Doc from rx.Subscriber.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. Override this method to add any useful initialization to your subscription, for instance to initiate backpressure. Annotations @Override

onStart

back to summary

public void onStart()

Overrides rx.Subscriber.onStart.

Doc from rx.Subscriber.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. Override this method to add any useful initialization to your subscription, for instance to initiate backpressure.

Annotations

@Override

peek	back to summary
public Object peek() Implements rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.peek. Doc from rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.peek. 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. Returns:Object the next element or null if no next element available Annotations @Override

peek

back to summary

public Object peek()

Implements rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.peek.

Doc from rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.peek.

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.

Returns:Object

the next element or null if no next element available

Annotations

@Override

poll	back to summary
public Object poll() Implements rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.poll. Doc from rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.poll. Override this method to poll (consume) the next element, null meaning no next element available now. Returns:Object the next element or null if no next element available Annotations @Override

poll

back to summary

public Object poll()

Implements rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.poll.

Doc from rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback.poll.

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

Returns:Object

the next element or null if no next element available

Annotations

@Override

public Class OperatorOnBackpressureBuffer<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OperatorOnBackpressureBuffer.BufferSubscriber<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OperatorOnBackpressureBuffer.Holder

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail