RxJava - Operatör Oluşturma

Aşağıda, bir Gözlemlenebilir oluşturmak için kullanılan operatörler verilmiştir.

Sr.No.	Operatör ve Açıklama
1	Create Sıfırdan bir Gözlemlenebilir oluşturur ve gözlemci yönteminin programlı olarak çağırmasına izin verir.
2	Defer Bir gözlemci abone olana kadar bir Observable oluşturmayın. Her gözlemci için taze bir gözlemlenebilir yaratır.
3	Empty/Never/Throw Sınırlı davranışa sahip bir Gözlemlenebilir oluşturur.
4	From Bir nesneyi / veri yapısını bir Gözlemlenebilir'e dönüştürür.
5	Interval Belirtilen zaman aralığı boşluğuyla sırayla bir Gözlemlenebilir yayan tamsayı oluşturur.
6	Just Bir nesneyi / veri yapısını, aynı veya aynı türde nesneleri yaymak için Gözlemlenebilir'e dönüştürür.
7	Range Belirli bir aralıkta bir Gözlemlenebilir yayan tamsayı oluşturur.
8	Repeat Art arda sırayla bir Observable yayan tamsayı oluşturur.
9	Start Bir işlevin dönüş değerini yaymak için bir Observable oluşturur.
10	Timer Belirli bir gecikmeden sonra tek bir öğe yaymak için bir Gözlemlenebilir oluşturur.

Operatör Örneği Oluşturma

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