typescript - 如何在 rxjs 中创建一个在 1 秒后抛出错误的模拟 API 调用？

Question

在这里玩代码=> https://stackblitz.com/edit/playground-rxjs-f8xjsh

你好， 我正在尝试模拟一个失败的 API 调用，它将在 subscribe() { Error: } 部分发出错误值。

import { from, of, pipe, forkJoin, interval, AsyncSubject, BehaviorSubject,defer, Subject, timer, observable, throwError } from 'rxjs';
import { concatMap, map, mergeMap, zipWith, delay, tap, concatAll, concat, concatWith, switchMap, catchError } from 'rxjs/operators';

const apiCall = (callNumber, isError=false) => of('Api Call Result ' + callNumber).pipe(
  tap(_=>console.log('Calling Api ' + callNumber)),
  delay(1000),
  tap(_=> throwError(() => new Error('ERROR')))
);

apiCall(99,true).subscribe({
  next: x=>console.log(x),
  error: e=>console.log(e)
});

目前错误没有被捕获，即被记录。 有人可以帮忙吗？

Stackblitz => https://stackblitz.com/edit/playground-rxjs-f8xjsh

Answer 1

这是一个工作示例，灵感来自 @JSmart523

const apiCall = (callNumber: number, isError = false) =>
  of('Api Call Result ' + callNumber).pipe(
    tap((_) => console.log('some log before')),
    delay(1000),
    switchMap((_) => {
      if (isError) {
        throw new Error(`ERROR`);
      } else {
        return of(_);
      }
    })
  );

apiCall(99, true).subscribe({
  next: (x) => console.log(x),
  error: (e: Error) => console.log(e.message),
});