rx.internal.operators

Class OperatorTake<T>

  • 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.

    • Constructor Detail

      • OperatorTake

        public OperatorTake(int limit)