วนซ้ำสัญญาซ้ำ ๆ

คุณสามารถบรรลุสิ่งที่คุณต้องการได้ด้วยตัวดำเนินการ flatMap ของ Observable

getGroups(group: string) {

    return this.http.get(`/group/{group}`).flatMap(response => {
        if (response.children.length === 0) { // you hit a leaf, stop recursion here
             return Observable.of(response);
        } else { // there are more levels to go deeper
             return this.getGroups(response.children[0].groupName);
        }
    });
}

แก้ไข โดยใช้สัญญา

สมมติว่าคุณใช้ GroupService ซึ่งส่งคืนข้อมูลแทนที่จะเป็น HttpClient คุณสามารถแปลง Promise เป็น Observable ด้วยตัวดำเนินการ fromPromise

getGroups(group: string) {

    return Observable.fromPromise(this.groupService.get(group)).flatMap(response => {
        if (response.children.length === 0) { // you hit a leaf, stop recursion here
             return Observable.of(response);
        } else { // there are more levels to go deeper
             return this.getGroups(response.children[0].groupName);
        }
    });
}

แก้ไข 2 การใช้บริการนี้

ลองมาดูตัวอย่างของคุณกัน คุณมีการติดตาม json

{
    "groupName": "Group_1", 
    "children" : ["Group_A", "Group_B"]
}

ในไฟล์ส่วนประกอบของคุณ คุณเรียกใช้บริการดังต่อไปนี้

...
this.recursiveGroupService.getGroups("Group_1")
    .subscribe(response => {
        // at this point response will be `Group_A`
    })

แก้ไข 3 รับวัตถุทั้งหมด

คราวนี้เราจะใช้ forkJoin และเรียก getGroups สำหรับรายการลูกทั้งหมดและรวบรวมผลลัพธ์ในอาร์เรย์ children

หมายเหตุ: ฉันยังไม่ได้ทดสอบโค้ดนี้ด้วยตนเอง มันอาจมีข้อผิดพลาดบางอย่าง ถ้ามีก็แจ้งให้ผมทราบด้วย

import { forkJoin, of } from 'rxjs';
import { map } from 'rxjs/operators';

getGroups(group: string) {
    let retVal;
    return Observable.fromPromise(this.groupService.get(group)).flatMap(response => {
        retVal = {
             groupName: response.groupName
        };
        if (response.children.length === 0) { // you hit a leaf, stop recursion here
             return of(retVal);
        } else { // there are more levels to go deeper
             // this will create list of observable for each child
             const children$ = response.children.map(
                       child => this.getGroups(child)); 
             // forkJoin will execute these observables in parallel
             return forkJoin(children$).pipe(
                  map(results => {
                      // results is an array containing children data
                      retVal.children = results;

                      return retVal;
                  })
             );
         }
    });
}

คุณสามารถใช้ Promise.all เพื่อแก้ไขลูกที่ลึกกว่าแบบวนซ้ำ จากนั้นนำผลลัพธ์ (อาร์เรย์) เพื่อสร้างวัตถุเพื่อแก้ไขสัญญาด้วย:

getGroups(groupName = "Group A") {
    return this.getGroupChildren(groupName).then((result) =>
        Promise.all(result.data.map( ({groupName}) => this.getGroups(groupName) ))
    ).then(children => ({ groupName, children }));
}

ดังนั้นมูลค่าที่สัญญาไว้อาจเป็นดังนี้:

[{
    groupName: "Group A",
    children: [{
        groupName: "Group A1",
        children: []
    },  {
        groupName: "Group A2",
        children: []
    }]
}]