RxJava - Operator Utilitas

Berikut adalah operator yang sering berguna dengan Observables.

Sr.No.	Operator & Deskripsi
1	Delay Daftarkan tindakan untuk menangani peristiwa siklus hidup yang dapat diamati.
2	Materialize/Dematerialize Merupakan item yang dipancarkan dan pemberitahuan dikirim.
3	ObserveOn Tentukan penjadwal yang akan diamati.
4	Serialize Force Observable untuk melakukan panggilan serial.
5	Subscribe Beroperasi berdasarkan emisi item dan pemberitahuan seperti selesai dari Observable
6	SubscribeOn Tentukan penjadwal yang akan digunakan oleh Observable ketika dilanggan.
7	TimeInterval Ubah sebuah Observable menjadi indikasi jumlah waktu yang telah berlalu di antara emisi.
8	Timeout Masalah pemberitahuan kesalahan jika waktu tertentu terjadi tanpa mengeluarkan item apapun.
9	Timestamp Lampirkan stempel waktu ke setiap item yang dipancarkan.
9	Using Menciptakan sumber daya sekali pakai atau umur yang sama seperti yang Dapat Diamati.

Contoh Operator Utilitas

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

ObservableTester.java

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