RxJava - उपयोगिता ऑपरेटर

निम्नलिखित वे ऑपरेटर हैं जो अक्सर वेधशालाओं के साथ उपयोगी होते हैं।

अनु क्रमांक।	ऑपरेटर और विवरण
1	Delay अवलोकनीय जीवन-चक्र की घटनाओं को संभालने के लिए कार्रवाई रजिस्टर करें।
2	Materialize/Dematerialize भेजे गए आइटम का प्रतिनिधित्व करता है और अधिसूचना भेजी जाती है।
3	ObserveOn अनुसूचक का अवलोकन करने के लिए निर्दिष्ट करें।
4	Serialize सीरीयस कॉल करने के लिए फोर्स ऑब्जर्वेबल।
5	Subscribe वेधशाला से पूर्ण की तरह वस्तुओं और सूचनाओं के उत्सर्जन पर काम करते हैं
6	SubscribeOn जब वह सब्सक्राइब किया जाता है, तो अवलोकनकर्ता द्वारा उपयोग किए जाने वाले अनुसूचक को निर्दिष्ट करें।
7	TimeInterval उत्सर्जन के बीच बीता समय की मात्रा के संकेत का उत्सर्जन करने के लिए एक अवलोकन के रूप में परिवर्तित करें।
8	Timeout यदि किसी भी आइटम को छोड़ने के बिना निर्दिष्ट समय होता है, तो त्रुटि अधिसूचना जारी करता है।
9	Timestamp उत्सर्जित प्रत्येक आइटम के लिए टाइमस्टैम्प संलग्न करें।
9	Using ऑब्जर्वेबल के रूप में एक डिस्पोजेबल संसाधन या एक ही जीवन काल बनाता है।

उपयोगिता ऑपरेटर उदाहरण

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