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

Verifikasi Hasilnya

Kompilasi kelas menggunakan javac kompiler sebagai berikut -

C:\RxJava>javac ObservableTester.java

Sekarang jalankan ObservableTester sebagai berikut -

C:\RxJava>java ObservableTester

Itu harus menghasilkan keluaran berikut -

ABCDEFG