尝试在Angular 2项目中将多个observable合并为一个

userService.getSiteUsers(siteId: string): Observable<SiteUser[]>;

哪里

export class SiteUser {
    site_id: string;
    user_id: string;
}

和

userService.getUser(user_id: string): Observable<User>;

哪里

export class User {
    id: string;
    name: string;
    email: string;
    ....
}

所以我必须做以下事情：

>调用siteUsers API以获取特定站点的所有用户ID
>对于每个用户id,请进行getUser API调用以获取用户详细信息

我可以轻松地做到这一点

let users: User[] = []; // this is bound in html view to a table
this.userService.getSiteUsers("my site id")
                .subscribe((siteUsers) => {
                    for (let siteUser of siteUsers) {
                        this.userService.getUser(siteUser.user_id)
                                        .subscribe((user) => {
                                            users.push(user);
                                        });
                    }
                });

但这种方法感觉很脏或很麻烦.我确信有一种更清晰的Observable方法.我是Observables的新手,但据我所知,我应该可以做这样的事情(不是selectMany和mergeAll函数只是我的猜测,我尝试过它并没有用,我甚至找不到selectMany在rxjs库))

获取站点用户可观察数组 – >对于可观察数组中的每个元素,创建用户可观察 – >将它们全部合并到可观察的用户数组中 – >订阅,所以像这样：

this.userService.getSiteUsers("my site id") 
                .selectMany((siteUser) => this.userService.getUser(user))
                .mergeAll()
                .subscribe((users) => {
                    this.users = users; 
                });

有人可以帮助,我不能让它工作

编辑 – – –

也许这样的事情

this.userService.getSiteUsers("my site id")
    .switchMap(
       (siteUsers) => {
         let userQueries: Observable<User>[] = [];
         for (let siteUser of siteUsers) {
            userQueries.push(this.userService.getUser(siteUser.user_id));
         }

         return Observable.forkJoin(userQueries);
       }
    )
    .subscribe((users) => {
        this.users = users;
    });