RxJava - Hizmet Operatörleri

Gözlemlenebilirler ile genellikle yararlı olan operatörler aşağıdadır.

Sr.No.	Operatör ve Açıklama
1	Delay Gözlemlenebilir yaşam döngüsü olaylarını işlemek için eylem kaydedin.
2	Materialize/Dematerialize Yayılan öğeyi ve gönderilen bildirimi temsil eder.
3	ObserveOn Gözlemlenecek planlayıcıyı belirtin.
4	Serialize Gözlemlenebilirliği seri hale getirilmiş aramalar yapmaya zorla.
5	Subscribe Gözlemlenebilir bir cihazdan tamamlanmış gibi öğelerin ve bildirimlerin emisyonları üzerinde çalışın
6	SubscribeOn Abone olduğunda bir Observable tarafından kullanılacak planlayıcıyı belirtin.
7	TimeInterval Bir Gözlemlenebilir Öğeyi, emisyonlar arasında geçen zaman miktarının göstergelerini yayacak şekilde dönüştürün.
8	Timeout Herhangi bir öğe yaymadan belirtilen süre oluşursa hata bildirimi verir.
9	Timestamp Yayınlanan her öğeye zaman damgası ekleyin.
9	Using Tek kullanımlık bir kaynak oluşturur veya Gözlemlenebilir ile aynı ömrü oluşturur.

Yardımcı Operatör Örneği

C: \> RxJava'da seçtiğiniz herhangi bir düzenleyiciyi kullanarak aşağıdaki Java programını oluşturun.

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