rxjsは、エラーの直後にエラーの直後にobservableを完了します。

Question

observableを通して一連のコンテンツをストリーミングしようとしていますが、最初のエラーの後に停止します。同じように動作するので、これをアイテムの配列と考えるのは簡単です。 observable.emptyを返し

1. 私は
2. はキャッチを（実行要求の約束としてURLを呼び出すURL
3. に各項目をマッピングする項目
4. の配列から、観察を作成しています） （）RxJS 5による誤り

の場合には：

rx.Observable.from(array) 
    .map(self.createUrl) 
    .flatMap(x => { 
      var options = { 
      uri: url, 
      headers: { 
       "Content-Type": "application/json" 
      }; 
      return rx.Observable.fromPromise(request-promise(options)); 
     }) 
    .catch(() => { 
    return rx.Observable.empty();}) 
    .subscribe(x => console.log('success:', x), 
      e => console.log('error'), 
      () => console.log('complete')); 

を

このシーケンスを実行すると、最初のエラーが発生した後にコードが停止します。私は＃4の空の観測可能性が観察可能なものを終了していると思われますが、私はなぜそれがわかりません。

私の望むプロセスは、配列に含まれるすべてのアイテムがエラーに関係なく処理されることです。最終的にすべての正常なアイテムを処理し、各エラーの後に再開します。

Answer 1

あなただけflatMap内catch()を配置する必要があります：

rx.Observable.from(array) 
    .map(self.createUrl) 
    .flatMap(x => { 
    var options = { 
     uri: url, 
     headers: { 
     "Content-Type": "application/json" 
     } 
    }; 
    return rx.Observable 
     .fromPromise(request-promise(options)) 
     .catch(() => rx.Observable.empty()); 
    }) 
    .subscribe(x => console.log('success:', x), 
      e => console.log('error'), 
      () => console.log('complete')); 

さて、内部観察可能で、それはすぐにキャッチされるだろうと.flatMap()を介してメインストリームに伝播しないエラーを発するとき。