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

परिणाम सत्यापित करें

का उपयोग कर वर्ग संकलित करें javac संकलक निम्नानुसार है -

C:\RxJava>javac ObservableTester.java

अब वेधशाला चलाने के लिए निम्नानुसार है -

C:\RxJava>java ObservableTester

यह निम्नलिखित उत्पादन का उत्पादन करना चाहिए -

ab