آموزش عملگر ها یا اپراتور های Take و TakeLast در RxJava

Observable
        .range(1, 10)
        .take(4)
        .subscribe(new Observer() {
            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG, "Subscribed");
            }  
     @Override
       public void onNext(Integer integer) {
           Log.d(TAG, "onNext: " + integer);
       }

       @Override
       public void onError(Throwable e) {

       }

       @Override
       public void onComplete() {
           Log.d(TAG, "Completed");
       }
   });

 Observable
        .range(1, 10)
        .takeLast(4)
        .subscribe(new Observer() {
            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG, "Subscribed");
            }
       @Override
       public void onNext(Integer integer) {
           Log.d(TAG, "onNext: " + integer);
       }

       @Override
       public void onError(Throwable e) {

       }

       @Override
       public void onComplete() {
           Log.d(TAG, "Completed");
       }
   });