RxJava - Operator Transformasi

Berikut adalah operator yang digunakan untuk mengubah item yang dipancarkan dari Observable.

Sr.No.	Operator & Deskripsi
1	Buffer Mengumpulkan item dari Observable ke dalam bundel secara berkala dan kemudian memancarkan bundelnya, bukan item.
2	FlatMap Digunakan dalam observabel bersarang. Mengubah item menjadi Observable. Kemudian ratakan item menjadi satu Observable.
3	GroupBy Bagilah Observable menjadi set Observable yang diatur menurut kunci untuk memancarkan kelompok item yang berbeda.
4	Map Terapkan fungsi ke setiap item yang dipancarkan untuk mengubahnya.
5	Scan Terapkan fungsi ke setiap item yang dipancarkan, secara berurutan dan kemudian berikan nilai yang berurutan.
6	Window Mengumpulkan item dari Observable ke jendela Observable secara berkala dan kemudian memancarkan jendela, bukan item.

Contoh Transformasi Operator

Buat program Java berikut menggunakan editor pilihan Anda di, misalnya, C: \> RxJava.

ObservableTester.java

import io.reactivex.Observable;
//Using map operator to transform 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
         .map(String::toUpperCase)
         .subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}