RxJava - सशर्त संचालक

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

अनु क्रमांक।	ऑपरेटर और विवरण
1	All दिए गए मानदंडों को पूरा करने के लिए उत्सर्जित सभी वस्तुओं का मूल्यांकन करता है।
2	Amb पहले वेधशाला से सभी वस्तुओं का उत्सर्जन करता है केवल कई वेधशालाएं दी जाती हैं।
3	Contains जांचता है कि क्या कोई ऑब्जर्वेबल किसी विशेष वस्तु का उत्सर्जन करता है या नहीं।
4	DefaultIfEmpty डिफ़ॉल्ट आइटम का उत्सर्जन करता है अगर ऑब्जर्वेबल कुछ भी उत्सर्जित नहीं करता है।
5	SequenceEqual जाँचता है कि क्या दो वेधशालाएँ वस्तुओं के समान अनुक्रम का उत्सर्जन करती हैं।
6	SkipUntil पहली ऑब्जर्वेबल द्वारा उत्सर्जित वस्तुएं, जब तक कि दूसरी ऑब्जर्वेबल एक आइटम का उत्सर्जन नहीं करती है।
7	SkipWhile एक पर्यवेक्षित द्वारा उत्सर्जित वस्तुओं को तब तक त्यागें जब तक कि दी गई स्थिति झूठी न हो जाए।
8	TakeUntil एक ऑब्जर्वेबल द्वारा एक दूसरे ऑब्जर्वेबल के बाद उत्सर्जित वस्तुओं को त्यागता है।
9	TakeWhile एक निर्दिष्ट स्थिति के झूठे होने के बाद एक ऑब्जर्वेबल द्वारा उत्सर्जित वस्तुओं को त्यागें।

सशर्त संचालक उदाहरण

C: \> RxJava, अपनी पसंद के किसी भी संपादक का उपयोग करके निम्नलिखित जावा प्रोग्राम बनाएं।

ObservableTester.java

import io.reactivex.Observable;
//Using defaultIfEmpty operator to operate on an Observable
public class ObservableTester  {
   public static void main(String[] args) {    
      final StringBuilder result = new StringBuilder();
      Observable.empty()
      .defaultIfEmpty("No Data")
      .subscribe(s -> result.append(s));
      System.out.println(result);
      String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
      final StringBuilder result1 = new StringBuilder();
      Observable.fromArray(letters)
      .firstElement()
      .defaultIfEmpty("No data")   
      .subscribe(s -> result1.append(s));
      System.out.println(result1);
   }
}