RxJS abhängige Aufgaben in die Warteschlange stellen

Wenn ich ein Array von Arrays wie dieses habe

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

und ich möchte durch jedes Elternteil und durch ihre Kinder in Serien blättern, damit ich das nächste Elternteil erst dann starte, wenn alle Kinder verarbeitet wurden (einige lange asynchrone Prozesse). Wie mache ich das mit RxJS?

Ich habe es versucht:

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);

Aber ich bekomme alle Eltern abgemeldet und dann alle Kinder.

Antworten auf die Frage(4)

Ihre Antwort auf die Frage