Rxjava-filtering-operators

RxJava-フィルタリング演算子

以下は、Observableから項目を選択的に送信するために使用される演算子です。

Sr.No.	Operator & Description
1	Debounce 別のアイテムを発行せずにタイムアウトが発生した場合にのみ、アイテムを発行します。
2	Distinct 一意のアイテムのみを発行します。
3	ElementAt Observableによって発行されたnインデックスのアイテムのみを発行します。
4	Filter 指定された述語関数を渡すアイテムのみを発行します。
5	First 指定された基準に合格した最初のアイテムまたは最初のアイテムを発行します。
6	IgnoreElements Observableからアイテムを発行せず、完了をマークします。
7	Last Observableから最後の要素を発行します。
8	Sample 指定された時間間隔で最新のアイテムを発行します。
9	Skip Observableから最初のn個のアイテムをスキップします。
10	SkipLast Observableの最後のn個のアイテムをスキップします。
11	Take Observableから最初のn個のアイテムを取得します。
12	TakeLast Observableから最後のn個のアイテムを取得します。

フィルタリング演算子の例

C：\> RxJavaなどで選択したエディターを使用して、次のJavaプログラムを作成します。

ObservableTester.java

import io.reactivex.Observable;
//Using take operator to filter an Observable
public class ObservableTester  {
   public static void main(String[] args) {
      String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
      final StringBuilder result = new StringBuilder();
      Observable<String> observable = Observable.fromArray(letters);
      observable
         .take(2)
         .subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}

結果を確認する

次のように javac コンパイラを使用してクラスをコンパイルします-

C:\RxJava>javac ObservableTester.java

今ObservableTesterを次のように実行します-

C:\RxJava>java ObservableTester

それは次の出力を生成する必要があります-

ab