Modifier and Type	Class and Description
pack-priv static class	ScalarSynchronousObservable.JustOnSubscribe<T> The OnSubscribe callback for the Observable constructor.
pack-priv static class	ScalarSynchronousObservable.ScalarAsyncOnSubscribe< the value type T> The OnSubscribe implementation that creates the ScalarAsyncProducer for each incoming subscriber.
pack-priv static class	ScalarSynchronousObservable.ScalarAsyncProducer< the value type T> Represents a producer which schedules the emission of a scalar value on the first positive request via the given scheduler callback.
pack-priv static class	ScalarSynchronousObservable.WeakSingleProducer< the value type T> This is the weak version of SingleProducer that uses plain fields to avoid re-entrant invocation and as such is not thread-safe for concurrent request() calls.

Modifier and Type	Field and Description
pack-priv static final boolean	STRONG_MODE Indicates that the Producer used by this Observable should be fully thread-safe.
pack-priv final T	t The constant scalar value to emit on request.

Access	Constructor and Description
protected	ScalarSynchronousObservable(final T t)

Modifier and Type	Method and Description
public static < the value type T> ScalarSynchronousObservable<T>	Returns: the new Observable create(T the value to emit when requested t) Constructs a ScalarSynchronousObservable with the given constant value.
pack-priv static < the type of the scalar value T> Producer	Returns: the created Producer createProducer(Subscriber<? super T> the target subscriber s, T the value to emit v) Creates a scalar producer depending on the state of STRONG_MODE.
public T	Returns: the scalar constant value directly get() Returns the scalar constant value directly.
public < the result type R> Observable<R>	Returns: the new observable scalarFlatMap(final Func1<? super T, ? extends Observable<? extends R>> the mapper function that returns an Observable for the scalar value of this func) Given this scalar source as input to a flatMap, avoid one step of subscription and subscribes to the single Observable returned by the function.
public Observable<T>	Returns: the new observable scalarScheduleOn(final Scheduler the target scheduler scheduler) Customized observeOn/subscribeOn implementation which emits the scalar value directly or with less overhead on the specified scheduler.

STRONG_MODE	back to summary
pack-priv static final boolean STRONG_MODE Indicates that the Producer used by this Observable should be fully thread-safe. It is possible, but unlikely that multiple concurrent requests will arrive to just().

t	back to summary
pack-priv final T t The constant scalar value to emit on request.

ScalarSynchronousObservable	back to summary
protected ScalarSynchronousObservable(final T t)

Method Detail

create	back to summary
public static <T> ScalarSynchronousObservable<T> create(T t) Constructs a ScalarSynchronousObservable with the given constant value. Parameters <T> the value type t:T the value to emit when requested Returns:ScalarSynchronousObservable<T> the new Observable

create

back to summary

public static <T> ScalarSynchronousObservable<T> create(T t)

Constructs a ScalarSynchronousObservable with the given constant value.

Parameters

<T>: the value type
t:T: the value to emit when requested

Returns:ScalarSynchronousObservable<T>

the new Observable

createProducer	back to summary
pack-priv static <T> Producer createProducer(Subscriber<? super T> s, T v) Creates a scalar producer depending on the state of STRONG_MODE. Parameters <T> the type of the scalar value s:Subscriber<? super T> the target subscriber v:T the value to emit Returns:Producer the created Producer

createProducer

back to summary

pack-priv static <T> Producer createProducer(Subscriber<? super T> s, T v)

Creates a scalar producer depending on the state of STRONG_MODE.

Parameters

<T>: the type of the scalar value
s:Subscriber<? super T>: the target subscriber
v:T: the value to emit

Returns:Producer

the created Producer

get	back to summary
public T get() Returns the scalar constant value directly. Returns:T the scalar constant value directly

get

back to summary

public T get()

Returns the scalar constant value directly.

Returns:T: the scalar constant value directly

scalarFlatMap	back to summary
public <R> Observable<R> scalarFlatMap(final Func1<? super T, ? extends Observable<? extends R>> func) Given this scalar source as input to a flatMap, avoid one step of subscription and subscribes to the single Observable returned by the function. If the functions returns another scalar, no subscription happens and this inner scalar value will be emitted once requested. Parameters <R> the result type func:Func1<? super T, ? extends Observable<? extends R>> the mapper function that returns an Observable for the scalar value of this Returns:Observable<R> the new observable

scalarFlatMap

back to summary

public <R> Observable<R> scalarFlatMap(final Func1<? super T, ? extends Observable<? extends R>> func)

Given this scalar source as input to a flatMap, avoid one step of subscription and subscribes to the single Observable returned by the function.

If the functions returns another scalar, no subscription happens and this inner scalar value will be emitted once requested.

Parameters

<R>: the result type
func:Func1<? super T, ? extends Observable<? extends R>>: the mapper function that returns an Observable for the scalar value of this

Returns:Observable<R>

the new observable

scalarScheduleOn	back to summary
public Observable<T> scalarScheduleOn(final Scheduler scheduler) Customized observeOn/subscribeOn implementation which emits the scalar value directly or with less overhead on the specified scheduler. Parameters scheduler:Scheduler the target scheduler Returns:Observable<T> the new observable

scalarScheduleOn

back to summary

public Observable<T> scalarScheduleOn(final Scheduler scheduler)

Customized observeOn/subscribeOn implementation which emits the scalar value directly or with less overhead on the specified scheduler.

Parameters

scheduler:Scheduler: the target scheduler

Returns:Observable<T>

the new observable

rx.internal.util back to summary

pack-priv final Class ScalarSynchronousObservable.JustOnSubscribe<T>

Class Inheritance

extends Object
implements Observable.OnSubscribe<T>

java.lang.Object
rx.internal.util.ScalarSynchronousObservable.JustOnSubscribe

All Implemented Interfaces

rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function

The OnSubscribe callback for the Observable constructor.

Field Summary

Modifier and Type	Field and Description
pack-priv final T	value

Constructor Summary

Access	Constructor and Description
pack-priv	JustOnSubscribe(T value)

Method Summary

Modifier and Type	Method and Description
public void	call(Subscriber<? super T> s) Implements rx.functions.Action1.call.

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

Field Detail

value	back to summary
pack-priv final T value

Constructor Detail

JustOnSubscribe	back to summary
pack-priv JustOnSubscribe(T value)

Method Detail

call	back to summary
public void call(Subscriber<? super T> s) Implements rx.functions.Action1.call. Annotations @Override

call

back to summary

public void call(Subscriber<? super T> s)

Implements rx.functions.Action1.call.

Annotations

@Override

rx.internal.util back to summary

pack-priv final Class ScalarSynchronousObservable.ScalarAsyncOnSubscribe<T>

Class Inheritance

extends Object
implements Observable.OnSubscribe<T>

java.lang.Object
rx.internal.util.ScalarSynchronousObservable.ScalarAsyncOnSubscribe

All Implemented Interfaces

rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function

Type Parameters

<T>: the value type

The OnSubscribe implementation that creates the ScalarAsyncProducer for each incoming subscriber.

Field Summary

Modifier and Type	Field and Description
pack-priv final Func1<Action0, Subscription>	onSchedule
pack-priv final T	value

Constructor Summary

Access	Constructor and Description
pack-priv	ScalarAsyncOnSubscribe(T value, Func1<Action0, Subscription> onSchedule)

Method Summary

Modifier and Type	Method and Description
public void	call(Subscriber<? super T> s) Implements rx.functions.Action1.call.

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

Field Detail

onSchedule	back to summary
pack-priv final Func1<Action0, Subscription> onSchedule

value	back to summary
pack-priv final T value

Constructor Detail

ScalarAsyncOnSubscribe	back to summary
pack-priv ScalarAsyncOnSubscribe(T value, Func1<Action0, Subscription> onSchedule)

Method Detail

call	back to summary
public void call(Subscriber<? super T> s) Implements rx.functions.Action1.call. Annotations @Override

call

back to summary

public void call(Subscriber<? super T> s)

Implements rx.functions.Action1.call.

Annotations

@Override

rx.internal.util back to summary

pack-priv final Class ScalarSynchronousObservable.ScalarAsyncProducer<T>

Class Inheritance

extends AtomicBoolean
implements Producer, Action0

java.lang.Object
java.util.concurrent.atomic.AtomicBoolean
rx.internal.util.ScalarSynchronousObservable.ScalarAsyncProducer

All Implemented Interfaces

rx.functions.Action0, rx.functions.Action, rx.functions.Function, rx.Producer

Type Parameters

<T>: the value type

Represents a producer which schedules the emission of a scalar value on the first positive request via the given scheduler callback.

Field Summary

Modifier and Type	Field and Description
pack-priv final Subscriber<? super T>	actual
pack-priv final Func1<Action0, Subscription>	onSchedule
private static final long	serialVersionUID Hides java.util.concurrent.atomic.AtomicBoolean.serialVersionUID.
pack-priv final T	value Hides java.util.concurrent.atomic.AtomicBoolean.value.

Constructor Summary

Access	Constructor and Description
public	ScalarAsyncProducer(Subscriber<? super T> actual, T value, Func1<Action0, Subscription> onSchedule)

Method Summary

Modifier and Type	Method and Description
public void	call() Implements rx.functions.Action0.call.
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.
public String	toString() Overrides java.util.concurrent.atomic.AtomicBoolean.toString. Returns the String representation of the current value.

Field Detail

actual	back to summary
pack-priv final Subscriber<? super T> actual

onSchedule	back to summary
pack-priv final Func1<Action0, Subscription> onSchedule

serialVersionUID	back to summary
private static final long serialVersionUID Hides java.util.concurrent.atomic.AtomicBoolean.serialVersionUID.

value	back to summary
pack-priv final T value Hides java.util.concurrent.atomic.AtomicBoolean.value.

Constructor Detail

ScalarAsyncProducer	back to summary
public ScalarAsyncProducer(Subscriber<? super T> actual, T value, Func1<Action0, Subscription> onSchedule)

Method Detail

call	back to summary
public void call() Implements rx.functions.Action0.call. Annotations @Override

call

back to summary

public void call()

Implements rx.functions.Action0.call.

Annotations

@Override

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

toString	back to summary
public String toString() Overrides java.util.concurrent.atomic.AtomicBoolean.toString. Doc from java.util.concurrent.atomic.AtomicBoolean.toString. Returns the String representation of the current value. Returns:String the String representation of the current value Annotations @Override

toString

back to summary

public String toString()

Overrides java.util.concurrent.atomic.AtomicBoolean.toString.

Doc from java.util.concurrent.atomic.AtomicBoolean.toString.

Returns the String representation of the current value.

Returns:String

the String representation of the current value

Annotations

@Override

rx.internal.util back to summary

pack-priv final Class ScalarSynchronousObservable.WeakSingleProducer<T>

Class Inheritance

extends Object
implements Producer

java.lang.Object
rx.internal.util.ScalarSynchronousObservable.WeakSingleProducer

All Implemented Interfaces

rx.Producer

Type Parameters

<T>: the value type

This is the weak version of SingleProducer that uses plain fields to avoid re-entrant invocation and as such is not thread-safe for concurrent request() calls.

Field Summary

Modifier and Type	Field and Description
pack-priv final Subscriber<? super T>	actual
pack-priv boolean	once
pack-priv final T	value

Constructor Summary

Access	Constructor and Description
public	WeakSingleProducer(Subscriber<? super T> actual, T value)

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

actual	back to summary
pack-priv final Subscriber<? super T> actual

once	back to summary
pack-priv boolean once

value	back to summary
pack-priv final T value

Constructor Detail

WeakSingleProducer	back to summary
public WeakSingleProducer(Subscriber<? super T> actual, T value)

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.

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 final Class ScalarSynchronousObservable<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ScalarSynchronousObservable.JustOnSubscribe<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ScalarSynchronousObservable.ScalarAsyncOnSubscribe<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ScalarSynchronousObservable.ScalarAsyncProducer<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ScalarSynchronousObservable.WeakSingleProducer<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail