Angular2/rxjs：訂閱不開火mergeMaps＆forkJoins

Question

的可觀表達我有，有一個方法，它本質上是一種服務：

this.backend.getJSON(`${name}/book`).mergeMap(
    book => Observable.forkJoin(book.parts.map((partName: string) => 
    this.backend.getJSON(`${name}/${partName}/part`).mergeMap(
     part => Observable.forkJoin(part.sections.map((sectionName: string) => 
     this.backend.getJSON(`${name}/${partName}/${sectionName}/section`).mergeMap(
      section => Observable.forkJoin(section.chapters.map((chapterName: string) => 
      this.backend.getJSON(`${name}/${partName}/${sectionName}/${chapterName}/chapter`).map(chapter => { 
       this.transform(chapter.content, `${name}/${partName}/${sectionName}/${chapterName}`); 
       return chapter; 
      }))), 
      this.assignAndReturn('chapters'))), 
     this.assignAndReturn('sections'))))), 
    this.assignAndReturn('parts')); 

（我內聯 - 稍微簡化 - 一些所謂的方法，這就是爲什麼它是這樣一個龐大的表達，因此在getJSON ARGS重複）

assignAndReturn就是：

private assignAndReturn<T1, T2>(name: string) { 
    return (a: T1, b: T2) => { 
    a[name] = b; 
    return a; 
    }; 
} 

.subscribe(...)對此似乎不起作用。它似乎只能在表達樹中下移，而不是「成爲」獲得章節的途徑。

我真的不知道發生了什麼事。這幾乎就像我需要訂閱'內部'部分，但外部訂閱不會觸發...

Answer 1

你可以嘗試一個這樣的模式，利用flatMap。一旦前一個事件結束，flatMap將繼續由它的回調返回Observable。它有助於提高可讀性，並使您能夠沿途監視您的流。

import { Observable } from 'rxjs'; 

class Demo { 
    backend = { 
     // Simulated request 
     getJSON: (str, demoValue) => Observable.of(demoValue).delay(new Date(Date.now() + 1000)) 
    } 

    getBook(name) { 
     this.backend 
      // Get the book 
      .getJSON(`${name}/book`, name) 
      // Get the parts 
      .flatMap(book => { 
       // Observable.from() will create an observable event 
       // for each item in the array 
       return this.backend 
        .getJSON(`[Next URL]`, [`${book}/part1`, `${book}/part2`]) 
        .flatMap(parts => Observable.from(parts)); 
      }) 
      // Get the sections 
      .flatMap(part => { 
       return this.backend 
        .getJSON(`[Next URL]`, [`${part}/section1`, `${part}/section`]) 
        .flatMap(sections => Observable.from(sections)); 
      }) 
      // Get the chapters 
      .flatMap(section => { 
       return this.backend 
        .getJSON(`[Next URL]`, [`${section}/chapter1`, `${section}/chapter2`]) 
        .flatMap(chapters => Observable.from(chapters)); 
      }) 
      // etc. 
      .subscribe(console.log) 
    } 
} 

let t = new Demo(); 
t.getBook('cool'); 

此輸出：

cool/part1/section1/chapter1 
cool/part1/section1/chapter2 
cool/part1/section2/chapter1 
cool/part1/section2/chapter2 
cool/part2/section1/chapter1 
cool/part2/section1/chapter2 
cool/part2/section2/chapter1 
cool/part2/section2/chapter2