Rxjs运算符withLatestFrom未按预期工作

您已经通过管道将输出从userInput$传递到withLatestFrom,但是subscribe仍然不知道作为输出提供什么。这里你需要映射你的输出。

const example = this.userInput$
  .pipe(withLatestFrom(x => this.service.search(x)),
  map(([userInput, searchOutput ]) => {
    return {query: userInput, result: searchOutput};
  })
);
const subscribe = example.subscribe(val => console.log(val.result));

两项观察:

首先,你不是真的要 map 除非您的代码示例是一个打字错误,否则它应该是这样的:

const example = this.userInput$.pipe(
  withLatestFrom(x => this.service.search(x)),
  map(([userInput, searchOutput ]) => {
    return {query: userInput, result: searchOutput};
  })
);

其次, withLatestFrom 旨在提供由所提供的可观察对象发出的最新值,该值不接收和响应来自更接近于 switchMap . 请考虑以下内容:

const example = this.userInput$.pipe(
  switchMap(x => this.service.search(x).pipe(
    map(searchOutput => {
      return {query: x, result: searchOutput};
    })
  )),
);

请注意,这是假设 this.service.search 返回 Observable 回应。如果没有,你需要用 from 或 of 根据实际返回类型 search .