管道一个可观察的，以更新项目列表与来自api的结果

Question

我有一个可以观察到的项目列表。我需要管道observable以便每个项目将执行api调用，用api调用的结果更新自己，并最终提供observable项目的更新列表。

我可以使用哪种RXJS运算符来执行此操作？

Answer 1

如果你可以按顺序做，你可以尝试这样的方法

const items$ = from([{id: 1, name: 'a'}, {id: 2, name: 'b'}, {id: 3, name: 'c'}])

const request = async (data) => {
  // data here would be any single object in your array
  // and `doHttpRequest` is any function that returns the type
  // given the original object
  const type = await doHttpRequest(data)
  return {
    ...data,
    type
  }
}

const results$ = items$.pipe(
  // flatMap being used here since we're not returning
  // a synchronous value from request
  flatMap(request),
  toArray()
);

// somewhere else in your code
results$.subscribe(value => console.log(value));

如果省略toarray部分，可以将可观察对象保留为对象流，而不是在最后完成单个数组。