Class 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 java.lang.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 Summary

      Fields 
      Modifier and Type Field Description
      (package private) int limit  
    • Constructor Summary

      Constructors 
      Constructor Description
      OperatorTake​(int limit)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      Subscriber<? super T> call​(Subscriber<? super T> child)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait