Top Description Inners Fields Constructors Methods
rx.internal.operators

public final Class OperatorElementAt<T>

extends Object
implements Observable.Operator<T, T>
Class Inheritance
All Implemented Interfaces
rx.Observable.Operator, rx.functions.Func1, rx.functions.Function
Type Parameters
<T>
the value type
Imports
java.util.concurrent.atomic.AtomicBoolean, rx.*, .Observable.Operator
Returns the element at a specified index in a sequence.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
OperatorElementAt.InnerProducer

A producer that wraps another Producer and requests Long.MAX_VALUE when the first positive request() call comes in.

Field Summary

Modifier and TypeField and Description
pack-priv final T
defaultValue

pack-priv final boolean
hasDefault

pack-priv final int
index

Constructor Summary

AccessConstructor and Description
public
OperatorElementAt(int index)

public
OperatorElementAt(int index, T defaultValue)

private
OperatorElementAt(int index, T defaultValue, boolean hasDefault)

Method Summary

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

Implements rx.functions.Func1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

defaultValueback to summary
pack-priv final T defaultValue
hasDefaultback to summary
pack-priv final boolean hasDefault
indexback to summary
pack-priv final int index

Constructor Detail

OperatorElementAtback to summary
public OperatorElementAt(int index)
OperatorElementAtback to summary
public OperatorElementAt(int index, T defaultValue)
OperatorElementAtback to summary
private OperatorElementAt(int index, T defaultValue, boolean hasDefault)

Method Detail

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

Implements rx.functions.Func1.call.

Annotations
@Override
rx.internal.operators back to summary

pack-priv Class OperatorElementAt.InnerProducer

extends AtomicBoolean
implements Producer
Class Inheritance
All Implemented Interfaces
rx.Producer
A producer that wraps another Producer and requests Long.MAX_VALUE when the first positive request() call comes in.

Field Summary

Modifier and TypeField and Description
pack-priv final Producer
actual

private static final long
serialVersionUID

Hides java.util.concurrent.atomic.AtomicBoolean.serialVersionUID.

Constructor Summary

AccessConstructor and Description
public
InnerProducer(Producer actual)

Method Summary

Modifier and TypeMethod 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.util.concurrent.atomic.AtomicBoolean:
compareAndExchangecompareAndExchangeAcquirecompareAndExchangeReleasecompareAndSetgetgetAcquiregetAndSetgetOpaquegetPlainlazySetsetsetOpaquesetPlainsetReleasetoStringweakCompareAndSetweakCompareAndSetAcquireweakCompareAndSetPlainweakCompareAndSetReleaseweakCompareAndSetVolatile

Field Detail

actualback to summary
pack-priv final Producer actual
serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.atomic.AtomicBoolean.serialVersionUID.

Constructor Detail

InnerProducerback to summary
public InnerProducer(Producer actual)

Method Detail

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