RxJava - फ़िल्टरिंग ऑपरेटर

निम्नलिखित वे ऑपरेटर हैं जो एक ऑब्जर्वेबल से आइटम (च) का चयन करने के लिए उपयोग किए जाते हैं।

अनु क्रमांक।	ऑपरेटर और विवरण
1	Debounce किसी अन्य आइटम का उत्सर्जन किए बिना केवल टाइमआउट होने पर आइटम का उत्सर्जन करता है।
2	Distinct केवल अनूठी वस्तुओं का उत्सर्जन करता है।
3	ElementAt वेधशाला द्वारा उत्सर्जित n सूचकांक में केवल आइटम का उत्सर्जन करें।
4	Filter केवल उन वस्तुओं का उत्सर्जन करता है जो दिए गए विधेय फ़ंक्शन को पास करते हैं।
5	First पहले आइटम या पहले आइटम का उत्सर्जन करता है जो दिए गए मानदंडों को पारित करता है।
6	IgnoreElements ऑब्जर्वेबल से किसी भी आइटम का उत्सर्जन न करें लेकिन पूरा होने के निशान।
7	Last ओब्जर्वेबल से अंतिम तत्व का उत्सर्जन करता है।
8	Sample दिए गए समय अंतराल के साथ सबसे हालिया आइटम का उत्सर्जन करता है।
9	Skip एक ऑब्जर्वेबल से पहली n आइटमों को छोड़ता है।
10	SkipLast एक ऑब्जर्वेबल से अंतिम n आइटम को छोड़ता है।
1 1	Take एक ऑब्जर्वेबल से पहला n आइटम लेता है।
12	TakeLast एक ऑब्जर्वेबल से अंतिम n आइटम लेता है।

फ़िल्टरिंग ऑपरेटर उदाहरण

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

ObservableTester.java

import io.reactivex.Observable;
//Using take operator to filter 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
         .take(2)
         .subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}