एक अवलोकन योग्य बनाएं जो तर्क स्वीकार करेगा

Question

Observable एस बनाने के लिए उचित तरीका क्या है, यदि पैरामीटर स्वीकार करने में सक्षम हैं?

उदाहरण के लिए, मैं HTTP अनुरोध

Answer 1

parameterize सकता है आप उस के लिए Observable.create उपयोग कर सकते हैं:

public static Observable<String> createMyObservable(final String all, final Integer my, final Boolean parameters) { 
    return new Observable.create(new Observable.OnSubscribe<String>(){ 

     @Override 
     public void call(Subscriber<? super String> subscriber) { 
      // here you have access to all the parameters you passed in and can use them to control the emission of items: 

      subscriber.onNext(all); 
      if (parameters) { 
       subscriber.onError(...); 
      } else { 
       subscriber.onNext(my.toString()); 
       subscriber.onCompleted(); 
      } 
     } 
    }); 
} 

ध्यान दें कि सभी मापदंडों अंतिम के रूप में घोषित किया जाना चाहिए या कोड संकलन नहीं होंगे।

आप अपने इनपुट पैरामीटर समय के साथ बदल करने के लिए वे एक नमूदार खुद को हो सकता है और आप शायद combineLatest या zipmap या flatMap का उपयोग अपने अन्य observables साथ उनके मूल्यों गठबंधन करने के लिए कर सकता है, या संभवतः मूल्यों पर आधारित नई observables बनाने के लिए आशा करते हैं आपके इनपुट पर्यवेक्षकों का।