Top Inners Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeFromArray<T>

extends Object
implements Observable.OnSubscribe<T>
Class Inheritance
All Implemented Interfaces
rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Imports
java.util.concurrent.atomic.AtomicLong, rx.*, .Observable.OnSubscribe

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
OnSubscribeFromArray.FromArrayProducer<T>

Field Summary

Modifier and TypeField and Description
pack-priv final T[]
array

Constructor Summary

AccessConstructor and Description
public
OnSubscribeFromArray(T[] array)

Method Summary

Modifier and TypeMethod and Description
public void
call(Subscriber<? super T> child)

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

arrayback to summary
pack-priv final T[] array

Constructor Detail

OnSubscribeFromArrayback to summary
public OnSubscribeFromArray(T[] array)

Method Detail

callback to summary
public void call(Subscriber<? super T> child)

Implements rx.functions.Action1.call.

Annotations
@Override
rx.internal.operators back to summary

pack-priv final Class OnSubscribeFromArray.FromArrayProducer<T>

extends AtomicLong
implements Producer
Class Inheritance
All Implemented Interfaces
rx.Producer

Field Summary

Modifier and TypeField and Description
pack-priv final T[]
array

pack-priv final Subscriber<? super T>
child

pack-priv int
index

private static final long
serialVersionUID

Hides java.util.concurrent.atomic.AtomicLong.serialVersionUID.

Constructor Summary

AccessConstructor and Description
public
FromArrayProducer(Subscriber<? super T> child, T[] array)

Method Summary

Modifier and TypeMethod and Description
pack-priv void
fastPath()

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.
pack-priv void
slowPath(long r)

Inherited from java.util.concurrent.atomic.AtomicLong:
accumulateAndGetaddAndGetcompareAndExchangecompareAndExchangeAcquirecompareAndExchangeReleasecompareAndSetdecrementAndGetdoubleValuefloatValuegetgetAcquiregetAndAccumulategetAndAddgetAndDecrementgetAndIncrementgetAndSetgetAndUpdategetOpaquegetPlainincrementAndGetintValuelazySetlongValuesetsetOpaquesetPlainsetReleasetoStringupdateAndGetweakCompareAndSetweakCompareAndSetAcquireweakCompareAndSetPlainweakCompareAndSetReleaseweakCompareAndSetVolatile

Field Detail

arrayback to summary
pack-priv final T[] array
childback to summary
pack-priv final Subscriber<? super T> child
indexback to summary
pack-priv int index
serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.atomic.AtomicLong.serialVersionUID.

Constructor Detail

FromArrayProducerback to summary
public FromArrayProducer(Subscriber<? super T> child, T[] array)

Method Detail

fastPathback to summary
pack-priv void fastPath()
requestback 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
slowPathback to summary
pack-priv void slowPath(long r)