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