آموزش اپراتور یا عملگر Filter در RxJava

آموزش اپراتور یا عملگر Filter در RxJava ، در ادامه آموزش های عملگرهای RxJava در این پست به بررسی یک اپراتور دیگر یعنی Filter می پردازیم.

آموزش اپراتور یا عملگر Filter در RxJava

اپراتور Filter در RxJava

همچنین بخوانید: آموزش عملگر ها یا اپراتور های Distinct ، Reduce و Count در RxJava

اپراتور Filter این اجازه را به شما می دهد که تنها آیتم هایی را منتشر emit کنید که یک سری condition یا شرط که توسط شما تعریف می شود را داشته باشد.

در مثال زیر ما یک فیلتر برروی آیتم ها اعمال کردیم که تنها اعدادی که باقیمانده آنها 0 می شوند منتشر شوند.این فیلتر برروی تمامی آیتم ها بصورت تک به تک اعمال می شود و خروجی برگشت return داده می شود به subscribe و بلاک onNext

Observable
          .just(1, 2, 3, 4, 5, 6, 7, 8, 9)
          .filter(new Predicate() {
              @Override
              public boolean test(Integer integer) throws Exception {
                  return integer % 2 == 0;
              }
          })
          .subscribe(new DisposableObserver() {
              @Override
              public void onNext(Integer integer) {
                  Log.e(TAG, "Even: " + integer);
              }
         @Override
         public void onError(Throwable e) {

         }

         @Override
         public void onComplete() {

         }
     });

خروجی

همچنین بخوانید: آموزش اپراتور ها یا عملگر های Min ، Max ، Sum و Average در RxJava

Even: 2
Even: 4
Even: 6
Even: 8

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