Modifier and Type	Class and Description
pack-priv static class	DeferredScalarSubscriber.InnerProducer Redirects the downstream request amount bach to the DeferredScalarSubscriber.

Field Summary

Modifier and Type	Field and Description
protected final Subscriber<? super R>	actual The downstream subscriber.
pack-priv static final int	HAS_REQUEST_HAS_VALUE Value will be emitted.
pack-priv static final int	HAS_REQUEST_NO_VALUE Request came first.
protected boolean	hasValue Indicates there is a value available in value.
pack-priv static final int	NO_REQUEST_HAS_VALUE Value came first.
pack-priv static final int	NO_REQUEST_NO_VALUE Initial state.
pack-priv final AtomicInteger	state The state, see the constants below.
protected R	value The holder of the single value.

Constructor Summary

Access	Constructor and Description
public	DeferredScalarSubscriber(Subscriber<? super R> actual)

Method Summary

Modifier and Type	Method and Description
protected final void	complete() Signals onCompleted() to the downstream subscriber.
protected final void	complete(R the value to complete with value) Atomically switches to the terminal state and emits the value if there is a request for it or stores it for retrieval by `downstreamRequest(long)`.
pack-priv final void	downstreamRequest(long n)
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 ex) Implements rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public final void	setProducer(Producer producer to be used by this subscriber or the other subscriber (or recursively its other subscriber) to make requests from p) Overrides rx.Subscriber.setProducer. If other subscriber is set (by calling constructor `Subscriber(Subscriber)` or `Subscriber(Subscriber, boolean)`) then this method calls `setProducer` on the other subscriber.
pack-priv final void	setupDownstream()
public final void	subscribeTo(Observable<? extends T> the source Observable source) Links up with the downstream Subscriber (cancellation, backpressure) and subscribes to the source Observable.

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

Field Detail

actual	back to summary
protected final Subscriber<? super R> actual The downstream subscriber.

HAS_REQUEST_HAS_VALUE	back to summary
pack-priv static final int HAS_REQUEST_HAS_VALUE Value will be emitted.

HAS_REQUEST_NO_VALUE	back to summary
pack-priv static final int HAS_REQUEST_NO_VALUE Request came first.

hasValue	back to summary
protected boolean hasValue Indicates there is a value available in value.

NO_REQUEST_HAS_VALUE	back to summary
pack-priv static final int NO_REQUEST_HAS_VALUE Value came first.

NO_REQUEST_NO_VALUE	back to summary
pack-priv static final int NO_REQUEST_NO_VALUE Initial state.

state	back to summary
pack-priv final AtomicInteger state The state, see the constants below.

value	back to summary
protected R value The holder of the single value.

Constructor Detail

DeferredScalarSubscriber	back to summary
public DeferredScalarSubscriber(Subscriber<? super R> actual)

Method Detail

complete	back to summary
protected final void complete() Signals onCompleted() to the downstream subscriber.

complete back to summary

complete	back to summary
protected final void complete(R value) Atomically switches to the terminal state and emits the value if there is a request for it or stores it for retrieval by `downstreamRequest(long)`. Parameters value:R the value to complete with

protected final void complete(R value)

Atomically switches to the terminal state and emits the value if there is a request for it or stores it for retrieval by downstreamRequest(long).

Parameters

value:R: the value to complete with

downstreamRequest	back to summary
pack-priv final void downstreamRequest(long n)

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 ex) 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 ex:Throwable the exception encountered by the Observable Annotations @Override

public void onError(Throwable ex)

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

ex:Throwable: the exception encountered by the Observable

Annotations

@Override

setProducer back to summary

setProducer	back to summary
public final void setProducer(Producer p) Overrides rx.Subscriber.setProducer. Doc from rx.Subscriber.setProducer. If other subscriber is set (by calling constructor `Subscriber(Subscriber)` or `Subscriber(Subscriber, boolean)`) then this method calls `setProducer` on the other subscriber. If the other subscriber is not set and no requests have been made to this subscriber then `p.request(Long.MAX_VALUE)` is called. If the other subscriber is not set and some requests have been made to this subscriber then `p.request(n)` is called where n is the accumulated requests to this subscriber. Parameters p:Producer producer to be used by this subscriber or the other subscriber (or recursively its other subscriber) to make requests from Annotations @Override

public final void setProducer(Producer p)

Overrides rx.Subscriber.setProducer.

Doc from rx.Subscriber.setProducer.

If other subscriber is set (by calling constructor Subscriber(Subscriber) or Subscriber(Subscriber, boolean)) then this method calls setProducer on the other subscriber. If the other subscriber is not set and no requests have been made to this subscriber then p.request(Long.MAX_VALUE) is called. If the other subscriber is not set and some requests have been made to this subscriber then p.request(n) is called where n is the accumulated requests to this subscriber.

Parameters

p:Producer: producer to be used by this subscriber or the other subscriber (or recursively its other subscriber) to make requests from

Annotations

@Override

setupDownstream	back to summary
pack-priv final void setupDownstream()

subscribeTo	back to summary
public final void subscribeTo(Observable<? extends T> source) Links up with the downstream Subscriber (cancellation, backpressure) and subscribes to the source Observable. Parameters source:Observable<? extends T> the source Observable

subscribeTo

back to summary

public final void subscribeTo(Observable<? extends T> source)

Links up with the downstream Subscriber (cancellation, backpressure) and subscribes to the source Observable.

Parameters

source:Observable<? extends T>: the source Observable

rx.internal.operators back to summary

pack-priv final Class DeferredScalarSubscriber.InnerProducer

Class Inheritance

extends Object
implements Producer

java.lang.Object
rx.internal.operators.DeferredScalarSubscriber.InnerProducer

All Implemented Interfaces

rx.Producer

Redirects the downstream request amount bach to the DeferredScalarSubscriber.

Field Summary

Modifier and Type	Field and Description
pack-priv final DeferredScalarSubscriber<?, ?>	parent

Constructor Summary

Access	Constructor and Description
public	InnerProducer(DeferredScalarSubscriber<?, ?> parent)

Method Summary

Modifier and Type	Method and Description
public void	request(long the maximum number of items you want this Producer to produce, or `Long.MAX_VALUE` if you want the Producer to produce items at its own pace n) Implements rx.Producer.request. Request a certain maximum number of items from this Producer.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

parent	back to summary
pack-priv final DeferredScalarSubscriber<?, ?> parent

Constructor Detail

InnerProducer	back to summary
public InnerProducer(DeferredScalarSubscriber<?, ?> parent)

Method Detail

request back to summary

request	back to summary
public void request(long n) Implements rx.Producer.request. Doc from rx.Producer.request. Request a certain maximum number of items from this Producer. This is a way of requesting backpressure. To disable backpressure, pass `Long.MAX_VALUE` to this method. Requests are additive but if a sequence of requests totals more than `Long.MAX_VALUE` then `Long.MAX_VALUE` requests will be actioned and the extras may be ignored. Arriving at `Long.MAX_VALUE` by addition of requests cannot be assumed to disable backpressure. For example, the code below may result in `Long.MAX_VALUE` requests being actioned only. request(100); request(Long.MAX_VALUE-1); Parameters n:long the maximum number of items you want this Producer to produce, or `Long.MAX_VALUE` if you want the Producer to produce items at its own pace Annotations @Override

public void request(long n)

Implements rx.Producer.request.

Doc from rx.Producer.request.

Request a certain maximum number of items from this Producer. This is a way of requesting backpressure. To disable backpressure, pass Long.MAX_VALUE to this method.

Requests are additive but if a sequence of requests totals more than Long.MAX_VALUE then Long.MAX_VALUE requests will be actioned and the extras may be ignored. Arriving at Long.MAX_VALUE by addition of requests cannot be assumed to disable backpressure. For example, the code below may result in Long.MAX_VALUE requests being actioned only.

request(100);
request(Long.MAX_VALUE-1);

Parameters

n:long: the maximum number of items you want this Producer to produce, or Long.MAX_VALUE if you want the Producer to produce items at its own pace

Annotations

@Override

public abstract Class DeferredScalarSubscriber<T, R>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class DeferredScalarSubscriber.InnerProducer

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail