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

Observable.range(1, 10)
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
                 .subscribe(new Observer() {
                     @Override
                     public void onSubscribe(Disposable d) {
                }

                @Override
                public void onNext(Integer integer) {
                    Log.d(TAG, "onNext: " + integer);
                }

                @Override
                public void onError(Throwable e) {

                }

                @Override
                public void onComplete() {

                }
            });

Observable
          .range(1, 4)
          .repeat(3)
          .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");
         }
     });