修改 Angular 中的 Observable 和 return 新 Observable 并进行更改

Question

我有一个 Observable

obs1$ = this.otherService.getObservable() 类型为 number

我想创建一个使用此 Observable

的 return 值发出 Observable 的方法


 combined() {
    this.currentLambdaReactorState$.subscribe((e) => {
      let dto = of([
        {
          name: 'foo',
          value: e,
        },
      ])
        return dto
    });
  }

到目前为止这个方法没有 return 任何东西，我怎么能从那个方法 return 一个 Observable？

Answer 1

地图就是你想要的。

// replace any with your type (returned from currentLambdaReactorState$)
combined(): Observable<{name: string, value: any}> {
  return this.currentLambdaReactorState$.pipe(
    // shorthand object literal return
    map((e)=> ({name: 'foo', value: e})) 
  )
}

// usage
combined().subscribe((mappedValue) => {
  console.log(mappedValue); // {name: 'foo', value: e}
});

修改 Angular 中的 Observable 和 return 新 Observable 并进行更改

modify Observable in Angular and return new Observable with made changes

javascript

rxjs

angular

rxjs-observables