Lettable rxjs ऑपरेटरों के संयुक्त पाइप में त्रुटि पकड़ें

Question

हमने अपने अनुप्रयोगों में से एक को एंगुलर 5 में अपग्रेड कर दिया है, और 0xमें संक्रमण के रूप में आरएक्सजेएस v5.5 में पेश किया गया है।

इस वजह से, हमने .pipe() ऑपरेटर के साथ नए सिंटेक्स में हमारी अवलोकन योग्य पाइपलाइनों को फिर से लिखा है।

हमारे पिछले कोड .switchMap() अंदर इस प्रकार दिखाई देगा, एक .catch() साथ करता है, तो एक त्रुटि फेंक दिया जाता है के रूप में प्रभाव के संचालन को बाधित नहीं करने के लिए।

@Effect() 
loadData$ = this.actions$ 
.ofType(LOAD_DATA) 
.map((action: LoadData) => action.payload) 
.withLatestFrom(this.store.select(getCultureCode)) 
.switchMap(([payload, cultureCode]) => this.dataService.loadData(payload, cultureCode) 
    .map(result => { 
    if (!result) { 
     return new LoadDataFailed('Could not fetch data!'); 
    } else { 
     return new LoadDataSuccessful(result); 
    } 
    }) 
    .catch((err, caught) => { 
    return Observable.empty(); 
    }); 
); 

एक (यहाँ से निपटने त्रुटि सरलीकृत) dataService यह पकड़ लिया और हैंडल किया जाएगा करने के लिए कॉल में फेंक दिया त्रुटि के मामले में।

नई वाक्य रचना और .pipe() के उपयोग के साथ

, अब हम इस

@Effect() 
loadData$ = this.actions$ 
.ofType(LOAD_DATA) 
.pipe(
    map((action: LoadData) => action.payload), 
    withLatestFrom(this.store.select(getCultureCode)), 
    switchMap(([payload, cultureCode]) => this.dataService.loadData(payload, cultureCode)), 
    map(result => { 
    if (!result) { 
     return new LoadDataFailed('Could not fetch data!'); 
    } else { 
     return new LoadDataSuccessful(result); 
    } 
    }) 
); 

मैं कैसे इसी तरह से किसी भी फेंक दिया त्रुटियों नमूदार पाइप लाइन में, नए सिंटैक्स का उपयोग पकड़ कर सकते हैं है?

Answer 1

रीफैक्टरिंग के बाद mapswitchMap प्रक्षेपण से बाहर चला गया, इसलिए कोई भी त्रुटि बाहरी स्ट्रीम को बंद कर देगी। दोनों धाराओं बराबर रखने के लिए, आप प्रक्षेपण ही उस तरह में pipe उपयोग करने की आवश्यकता:

@Effect() 
loadData$ = this.actions$ 
.ofType(LOAD_DATA) 
.pipe(
    map((action: LoadData) => action.payload), 
    withLatestFrom(this.store.select(getCultureCode)), 
    switchMap(([payload, cultureCode]) => 
    this.dataService.loadData(payload, cultureCode) 
     .pipe(
     map(result => { 
      if (!result) { 
      return new LoadDataFailed('Could not fetch data!'); 
      } else { 
      return new LoadDataSuccessful(result); 
      } 
      }), 
     catchError((err, caught) => { 
      return Observable.empty(); 
     }) 
    ) 
) 
);