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

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

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

C:\RxJava>javac ObservableTester.java

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

C:\RxJava>java ObservableTester

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

abcdefg