Блог

У меня есть одна конечная точка для получения списка пользователей, а другая для получения списка квартир для каждого пользователя:

 getUsers() => Observable<User[]>;
getUserApartments(userId) => Observable<Apartment[]>`
  

Как мне объединить данные из двух в одну наблюдаемую:

 const usersWithApartments$: Observable<{ user: User, apartments: Apartment[] }[]> = getUsers().pipe(
    // users.map(user => { user, apartments: getUserApartments(user.id) }) <-- turn this pseudocode into Rxjs
);
  

Поскольку getUsers() тип возвращаемого значения — Users[] я предполагаю, что желаемый тип — это коллекция { user: User, apartments: Apartment[]> , а не один.

Пожалуйста, рассмотрите приведенную ниже реализацию:

 class UserApartments {
  user: User;
  apartments: Apartment[];
}
  

 const usersWithApartments$: Observable<UserApartments[]> = getUsers()
  .pipe(
    switchMap(users => forkJoin(
      users.map(user => getUserApartments(user.id).pipe(
        map(apartments => ({ user, apartments }))
      ))
    ))
  );
  

Это оно:

 const toUserWithApartmentsStream = (user: User) => getUserApartments(user.id).pipe(
  map((apartments: Apartment[]) => ({ user, apartments }))
);

const usersWithApartments$: Observable<{ user: User, apartments: Apartment[] }[]> =
  getUsers().pipe(
    switchMap((users: User[]) => users),
    concatMap((user: User) => toUserWithApartmentsStream(user)),
    toArray()
  );
  

Прямо сейчас getUserApartments будут выполняться последовательно один за другим, я мог бы написать mergeMap вместо concatMap и getUserApartments будут выполняться одновременно. Спасибо Рафи Хенигу за комментарий

Функция toUserWithApartmentsStream — это просто помощник, так что код выглядит чище. Я мог бы просто записать это встроенным внутри concatMap .