Package rx.internal.operators

Class OperatorTake<T>

java.lang.Object
rx.internal.operators.OperatorTake<T>
Type Parameters:
T - the value type
All Implemented Interfaces:
Func1<Subscriber<? super T>,Subscriber<? super T>>, Function, Observable.Operator<T,T>
public final class OperatorTake<T> extends Object implements Observable.Operator<T,T>
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 Details

    • limit

      final int limit

  • Constructor Details

    • OperatorTake

      public OperatorTake(int limit)

  • Method Details