RxJava - Membuat Operator

Berikut adalah operator yang digunakan untuk membuat Observable.

Sr.No. Operator & Deskripsi
1

Create

Membuat Observable dari awal dan memungkinkan metode pengamat untuk memanggil secara terprogram.

2

Defer

Jangan membuat Observable sampai pengamat berlangganan. Membuat observasi baru untuk setiap pengamat.

3

Empty/Never/Throw

Membuat Observable dengan perilaku terbatas.

4

From

Mengubah objek / struktur data menjadi Observable.

5

Interval

Membuat bilangan bulat yang dapat diamati secara berurutan dengan celah interval waktu yang ditentukan.

6

Just

Mengubah objek / struktur data menjadi Observable untuk memancarkan tipe objek yang sama atau sama.

7

Range

Membuat bilangan bulat yang dapat diamati dalam urutan rentang yang diberikan.

8

Repeat

Membuat bilangan bulat yang dapat diamati secara berurutan berulang kali.

9

Start

Membuat Observable untuk memancarkan nilai kembali dari suatu fungsi.

10

Timer

Membuat Observable untuk mengeluarkan satu item setelah penundaan tertentu.

Membuat Contoh Operator

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

ObservableTester.java

import io.reactivex.Observable;
//Using fromArray operator to create 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

Ini harus menghasilkan keluaran berikut -

ABCDEFG