RxJS“抛出新错误”与“可观察的抛出”

Observable.throw 在流中时返回错误。例如,我期待一个 Observable 但出于某种原因,我想返回一个错误。这些情况不可能使用 throw new Error()

var source = someStream$
    .flatMap(data => data?
             Rx.Observable.of(data): // Or any other async operation 
             Rx.Observable.throw('invalid data'));

在这里 flatMap 抛出新错误()