使用 Observable 而不是 Promise 来映射对象数组

Question

问题： 当我从服务器获取数据时，我得到了一些格式的对象：

{
  list: {
    pagination: {},
    entries: []
  }
}

我需要检查条目并更改它们。要更改它们，我需要为每个条目调用一些 REST API（例如：在第一次调用中，我将获取 id，对于每个 id，我需要获取真实数据）。在为每个对象完成所有 REST 调用之后，我需要更改其数据。所以 entry[i] = 从 id 到真实数据。

我用 Promises 解决了这个问题，但我想用 Observables 解决这个问题。

我尝试使用 rxjs 中的 map 和 concatMap 但没有成功。

代码：

public getUsers(queryBody?: SearchRequest): Observable<PersonPaging> {
    const searchRequest =
      queryBody ||
      this.searchService.makeSearchRequest(
        new Query({ type: ContentModel.TYPE_PERSON })
      );

    return this.searchService
      .search(searchRequest)
      .pipe(
        switchMap(async (resultSetPaging: ResultSetPaging) => {
          const users: PersonPaging = {
            list: {
              pagination: resultSetPaging.list.pagination,
              entries: []
            }
          };

          for (const rowEntry of resultSetPaging.list.entries) {
            const { properties } = rowEntry.entry;

            const personEntry = await this.getUser(
              properties[ContentModel.PROP_USERNAME]
            ).toPromise();

            const person: Person = personEntry.entry;
            person.avatarId = this.getUserAvatarImage(person);

            users.list.entries.push(personEntry);
          }

          return users;
        })
      );
  }

问题结束

代码进行中：

  return this.searchService.search(searchRequest).pipe(
      map((resultSetPaging: ResultSetPaging) => {
        return from(resultSetPaging.list.entries).pipe(
          concatMap(rowEntry => {
            const { properties } = rowEntry.entry;
            return from(
              this.getUser(properties[ContentModel.PROP_USERNAME])
            ).pipe(
              map(personEntry => {
                const person: Person = personEntry.entry;
                person.avatarId = this.getUserAvatarImage(person);
                return { person };
              })
            );
          })
        );
      })
    );

使用此代码，我可以让所有用户获得修改后的数据，但我没有获得我想要的分页对象。它调用了 x 次（x - 用户/条目数）

Answer 1

我不能 100% 确定您希望如何格式化，但这应该会让您接近。听起来您真正需要做的就是将Person 列表减少到users.list.entries 上的数组中？看起来像这样：

return this.searchService.search(searchRequest).pipe(
  map((resultSetPaging: ResultSetPaging) => {
    return from(resultSetPaging.list.entries).pipe(
      concatMap(rowEntry => {
        const { properties } = rowEntry.entry;
        return from(
          this.getUser(properties[ContentModel.PROP_USERNAME])
        ).pipe(
          map(personEntry => {
            const person: Person = personEntry.entry;
            person.avatarId = this.getUserAvatarImage(person);
            return { person };
          })
        );
      }),
      reduce(
        (users, personEntry) => {
          users.list.entries.push(personEntry);
          return users;
        },
        {
          list: {
            pagination: resultSetPaging.list.pagination,
            entries: []
          }
        }
      )
    );
  })
);

或者可能稍微干净一些（虽然是一样的）

return this.searchService.search(searchRequest).pipe(
  map((resultSetPaging: ResultSetPaging) =>
    from(resultSetPaging.list.entries).pipe(
      concatMap(rowEntry => {
        const { properties } = rowEntry.entry;
        return from(
          this.getUser(properties[ContentModel.PROP_USERNAME])
        );
      }),
      map(personEntry => {
        const person: Person = personEntry.entry;
        person.avatarId = this.getUserAvatarImage(person);
        return { person };
      }),
      reduce(
        (users, personEntry) => {
          users.list.entries.push(personEntry);
          return users;
        },
        {
          list: {
            pagination: resultSetPaging.list.pagination,
            entries: []
          }
        }
      )
    )
  )
);

---

除此之外：我还想知道您的第一张地图是否按预期工作。看起来您正在返回一个流，所以您可能想要 mergeMap 代替？

map((resultSetPaging: ResultSetPaging) =>
  from(resultSetPaging.list.entries).pipe(...

到

mergeMap((resultSetPaging: ResultSetPaging) =>
  from(resultSetPaging.list.entries).pipe(...