Top Description Fields Constructors Methods
rx.internal.operators

public final Class OperatorTake<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.AtomicLong, rx.*, .Observable.Operator, rx.plugins.RxJavaHooks
An Observable that emits the first num items emitted by the source Observable.

You can choose to pay attention only to the first num items emitted by an Observable by using the take operator. This operator returns an Observable that will invoke a subscriber's onNext function a maximum of num times before invoking onCompleted.

Field Summary

Modifier and TypeField and Description
pack-priv final int
limit

Constructor Summary

AccessConstructor and Description
public
OperatorTake(int limit)

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

limitback to summary
pack-priv final int limit

Constructor Detail

OperatorTakeback to summary
public OperatorTake(int limit)

Method Detail

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

Implements rx.functions.Func1.call.

Annotations
@Override