आरएक्स fromPromise और पुन: प्रयास

Question

तुम क्यों flatMapfromPromise की क्या ज़रूरत है पुन: प्रयास करें काम करने के लिए प्राप्त करने के लिए?

var responseStream = Rx.Observable.just('/error'). 
     flatMap(requestUrl => { 
      return Rx.Observable.fromPromise(_this.$http.get(requestUrl)); 
    }); 

    responseStream. 
     retry(3). 
     subscribe(
     function (x) { 
      console.log('Next: ' + x); 
     }, 
     function (err) { 
      console.log('Error: ' + err); 
     }, 
     function() { 
      console.log('Completed'); 
     }); 

मैं औपचारिक पर कटौती करने के लिए चाहते हैं और बस है ('/ त्रुटि' स्थिति 500 ​​रिटर्न):

Rx.Observable.fromPromise(_this.$http.get('error')). 
     retry(3). 
     subscribe(
     function (x) { 
      console.log('Next: ' + x); 
     }, 
     function (err) { 
      console.log('Error: ' + err); 
     }, 
     function() { 
      console.log('Completed'); 
     }); 

कि दूसरे मामले में XHR कॉल केवल है एक बार निष्पादित

Answer 1

क्योंकि Promises में पुनः प्रयास करने के लिए कोई एपीआई नहीं है। fromPromise सिर्फ Promise को लपेट रहा है और इसे इसके बजाय एक पर्यवेक्षक के माध्यम से उत्सर्जित कर रहा है। जब आप _this.$http.get('error') पर कॉल करते हैं तो आपने पहले ही Promise बनाया है और यह पहले से ही उड़ान में है, इसलिए विधि को फिर से कॉल किए बिना वादा को फिर से प्रयास करने का कोई तरीका नहीं है।

flatMap के साथ लपेटने के कारण यह काम करता है क्योंकि जब आप Observable को पुनः प्रयास करते हैं तो यह वास्तव में वादा उत्पन्न करने वाली विधि को फिर से निष्पादित कर रहा है।

यदि वर्बोसिटी वास्तव में आपको चोट पहुंचा रही है, तो एहसास करें कि fromPromise विधि को कॉल करने की आवश्यकता के बिना कई ऑपरेटरों Promises का समर्थन करते हैं।

तो अपने उदाहरण और भी अधिक बस defer का उपयोग कर

var responseStream = Rx.Observable.just('/error') 
     .flatMap(requestUrl => _this.$http.get(requestUrl)); 

    responseStream 
     .retry(3) 
     .subscribe(
      (x) => console.log('Next: ' + x), 
      (err) => console.log('Error: ' + err), 
     () => console.log('Completed')); 

या करने के लिए नीचे कम किया जा सकता:

Observable.defer(() => _this.$http.get('/error')) 
    .retry(3) 
    .subscribe(
     (x) => console.log('Next: ' + x), 
     (err) => console.log('Error: ' + err), 
    () => console.log('Completed'));