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