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

Sonucu Doğrulayın

Kullanarak sınıfı derleyin javac aşağıdaki gibi derleyici -

C:\RxJava>javac ObservableTester.java

Şimdi ObservableTester'ı aşağıdaki gibi çalıştırın -

C:\RxJava>java ObservableTester

Aşağıdaki çıktıyı üretmelidir -

abcdefg