Angular2/rxjs : 나는 본질적으로 방법을 가지고 서비스를 mergeMaps & forkJoins

Question

의 관찰 가능한 표현에 발사하지 구독 이는이 따라서 getJSON 인수의 반복과 같은 거대한 표현, 그리고 왜)

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