RxJS 排队相关任务

如果我有一个像这样的数组数组

{
    parent: [
        {
            name: 'stu',
            children: [
                {name: 'bob'},
                {name: 'sarah'}    
            ]
        },
        { 
          ...
        }
    ]
}

我想循环遍历每个父级并依次循环遍历它们的子级，这样我就不会启动下一个父级，直到所有子级都已处理完毕（一些漫长的异步过程），我该如何使用 RxJS 来做到这一点？

我已经尝试过这样做：

var doChildren = function (parent) {
    console.log('process parent', parent.name);
    rx.Observable.fromArray(parent.children)
    .subscribe(function (child) {
        console.log('process child', child.name);
        // do some Asynchronous stuff in here
    });
};

rx.Observable.fromArray(parents)
.subscribe(doChildren);

但我让所有家长退出，然后是所有孩子。

concatMap在这里效果更好。因为如果迭代子项是异步的，子项的顺序就会混乱。concatMap可以确保一次完成一位父母。

Rx.Observable.from(parents)
  .concatMap(function (p) {
    return Rx.Observable.from(p.children)
  })
  .subscribe();