RxJS:即使在源 observable 上使用 `shareReplay()`， `throwError()` 也会为每个 observable 单独执行

In lại 作者：行者123 更新时间：2023-12-04 09:57:51 27 4

const http$ = createHttpObservable('/api/courses');

const courses$ = http$
  .pipe(
    map(res => res['payload'] ),
    shareReplay(),
    catchError(err => {
      return throwError(err);
    })
  );

this.beginnerCourses$ = courses$
  .pipe(
    map(courses => courses
      .filter(course => course.category === 'BEGINNER')));

this.advancedCourses$ = courses$
  .pipe(
    map(courses => courses
      .filter(course => course.category === 'ADVANCED')));

}

const a=defer(()=>{
  console.log('run')
  return throwError(new Error('Error'))
}).pipe(shareReplay())

a.subscribe(console.log,console.error,()=>console.log('complete'))
a.subscribe(console.log,console.error,()=>console.log('complete'))

27 4 0

• javascript - RxJS - 为什么我要使用 throwError 而不是简单地抛出错误？

  首先，我要明确一点，我知道 Rx throwError 运算符和 JS 的 throw 关键字的区别。我只是想知道为什么要使用 throwError 运算符？我通过创建一个新的 observable

• rxjs - 如何使用 RxJS 延迟 throwError？

  正如预期的那样，以下代码在 5 秒后发出 42: const valueObservable = of(42).pipe(delay(5000)); valueObservable.subscribe

• php - fatal error - 调用未定义的方法 "Customersss::throwError()"

  我创建了一个类并尝试调用一个方法，但是在我的 错误日志 , 我收到回复 "Uncaught Error: Call to undefined method Customersss::throwErro

• javascript - Jasmine .and.throwError() 未被原始代码中的 .catch 捕获

  我正在为一个函数编写测试，并且必须触发该函数的 .catch 部分，但 Jasmine 的 spy 出于某种原因不能这样做。待测方法: foo(){ doStuff() .catch((error)

• angular - ".../node_modules/rxjs/Rx"没有导出成员 'throwError'

  Angular 文档谈到了一个“throwError”类，其导入语句如下所示 import { Observable, throwError } from 'rxjs'; 但我的编译器无法找到该类，并

• angular - throwError(error) 现在已弃用，但没有新的 Error(HttpErrorResponse)

  显然 throwError(error)现在已弃用。 VS Code 的 IntelliSense 建议 throwError(() => new Error('error') . new Error

• javascript - Node.js:遇到 mocha 问题并期望 to.throwError

  我正在尝试为 Node.js 构建一个简单的登录模块。我正在尝试以 TDD 方式进行操作，但我对它还是陌生的，所以任何有助于我更好地理解它的提示或资源都会很棒。 当我查询包含无效数据的数据库时，我的问

• Angular 7 (RxJs 6.x) - 如何使用 throwError

  我想在我的订阅者上使用第二个参数(错误)但不起作用。 我的 Observable 代码: return Observable.create(obs => { cognitoidentityserv

• angular - 当 rxjs throwError 重新抛出 http 错误响应时，自定义全局错误处理程序未命中

  目标:为服务器错误和应用程序错误(在 Typescript 代码中生成)提供全局错误处理程序。 如何:从同一工作空间内的 lib 项目中提供自定义 ErrorHandler。这是我的库结构: 我有以下

• RxJS:即使在源 observable 上使用 `shareReplay()`， `throwError()` 也会为每个 observable 单独执行

  我正在使用 RxJS shareReplay()可观察对象( courses$ )上的运算符，以在其他两个可观察对象( beginnerCourses$ 和 advancedCourses$ )之间共