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

آموزش عملگر ها یا اپراتور های Range و Repeat در RxJava ، در این پست از وب سایت تجاری اپ ما عملگر ها یا اپراتور های Range و Repeat در RxJava را مورد بررسی قرار خواهیم داد.

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

اپراتور Range در RxJava

همچنین بخوانید:
اپراتورها یا عملگرهای RxJava
آموزش اپراتور یا عملگر Just در RxJava
آموزش اپراتور یا عملگر From در RxJava

همانطور که از نام اپراتور Range مشخص است این اپراتور برای تولید یک یک بازه متوالی بین دو integer استفاده می شود.به مثال زیر توجه کنید:

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() {

                }
            });

خروجی

onNext: 1
onNext: 2
.
.
onNext: 9
onNext: 10

اپراتور Repeat در RxJava

همچنین بخوانید:
مفاهیم Observable و Observer در RxJava
آموزش الگوی MVVM و RxJava به صورت پروژه محور + سورس کد

اپراتور یا عملگر Repeat جهت ایجاد یک Observable برای انتشار یک سری آیتم به صورت تکراری به تعداد دفعاتی است که ما مشخص می کنیم.

در مثال زیر ما اعداد بین 1 تا 4 را 3 بار منتشر emit میکنیم با استفاده از اپراتور Repeat :

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");
         }
     });

خروجی

Subscribed
onNext: 1
onNext: 2
onNext: 3
onNext: 4
onNext: 1
onNext: 2
onNext: 3
onNext: 4
onNext: 1
onNext: 2
onNext: 3
onNext: 4
Completed

امیدوارم این اموزش برای شما مفید بوده باشد.