Rxjs Bedingung Fehlerfluss

Question

Ich erstelle im Wesentlichen eine Transaktion. Eine Vereinfachung würde wie folgt beschrieben:

1) Machen Sie einen Versprechen Anruf. 2) Wenn Fehler und error.code === "ConditionalCheckFailedException", den Fehler ignorieren und den Stream ohne Änderungen fortsetzen. 3) Wenn Fehler, Stream stoppen.

Die folgenden geben mir 1 und 3. Ich möchte mit dem Strom weitermachen, wenn ich eine bestimmte Ausnahme habe. Ist das möglich? ...

Im Moment habe ich:

//... stream that works to this point 
.concatMap((item) => { 
    const insertions = Rx.Observable.fromPromise(AwsCall(item)) 
     .catch(e => { 
      if (e.code === "ConditionalCheckFailedException") { 
       return item 
      } else { 
       throw e; 
      } 
     }); 
    return insertions.map(() => item); 
}) 
.concat // ... much the same 

Answer 1

So catch will eine Funktion, die eine neue Observable liefert.

Verwenden Sie stattdessen dies:

//... stream that works to this point 
.concatMap((item) => { 
    const insertions = Rx.Observable.fromPromise(AwsCall(item)) 
    .catch(e => e.code === "ConditionalCheckFailedException" 
     ? Rx.Observable.of(item) 
     : Rx.Observable.throw(e) 
    ) 
    /* depending on what AwsCall returns this might not be necessary: */ 
    .map(_ => item) 
    return insertions; 
}) 
.concat // ... much the same 

Quelle: http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#instance-method-catch