javascript - 在 rxjs Observable 中抛出错误

Question

我试图在 rxjs Observable 中抛出一个错误

 new Observable(subscriber => {
   Observable.throw("error1");
   return Observable.throw("error2");
 })
 .subscribe(
   () => {},
   err => console.error(err)
 );

错误 1 ​​未被捕获。

error2 给出编译错误:

Argument of type '(this: Observable<{}>, subscriber: Subscriber<{}>) => ErrorObservable<string>' is not assignable to parameter of type '(this: Observable<{}>, subscriber: Subscriber<{}>) => TeardownLogic'. Type 'ErrorObservable<string>' is not assignable to type 'TeardownLogic'

在可观察对象中抛出错误的正确方法是什么？

Answer 1

使用Subscriber.error :

new Rx.Observable(subscriber => {
  subscriber.error("error1");
  subscriber.error("error2"); // not called because a stream will be finalized after any error
})
.subscribe(
  () => {},
  err => console.error(err)
);

<script src="https://unpkg.com/rxjs/bundles/Rx.min.js"></script>